I think that would solve it!
Also, is there a major difference between these two approaches:
Copy code
# using .submit
cors = [my_task.submit(param1=p, return_state=True) for p in params]
states = await asyncio.gather(*cors)
# using .map
states = await my_task.map(param1=params, return_state=True)
Kelvin DeCosta
02/22/2023, 9:13 AM
I think there's also a slight type checking issue with
return_state=True
and
async
tasks
z
Zanie
02/22/2023, 3:10 PM
There's not a major difference
Zanie
02/22/2023, 3:11 PM
Type checking doesn't work with the return state kwarg, Python type checking doesn't support extending your function signature with additional options
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.