Barada Sahu
09/07/2022, 8:20 AMPrefectFuture
to a downstream task or does the task result always get evaluated and then passed as an argument?Mason Menges
09/07/2022, 3:11 PMBarada Sahu
09/07/2022, 3:28 PMdef test_flow(nums: list = None):
test_futures = [square.submit(num) for num in nums]
return do_cleanup.submit(test_futures)
do_cleanup
is receiving a list of returned values and not the futures