@Mason Menges the downstream task is receiving the evaluated result of the , even though I pass a PrefectFuture (returned object from .submit()) as the argument to it .
see below 👇
Copy code
def 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
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.