Charles Liu
08/12/2021, 6:44 PMKevin Kho
task(lambda x: len(x))(input)
would work in the Flow blockCharles Liu
08/12/2021, 6:45 PMKevin Kho
task.run()
in the Flow block because that it was the Flow block is doing. For a dict you either need an intermediate task to unpack it or pass the whole dict to the subsequent task
You might be able to do:
val1, va2 = task(lambda x: (x['val1'], x['val2']), nout=2)(input_Dict)
Kevin Kho
Charles Liu
08/12/2021, 6:49 PMCharles Liu
08/12/2021, 6:51 PM