Barada Sahu
09/06/2022, 8:59 AM@flow
def test_flow(nums: list = None):
test_futures = [square.submit(num) for num in nums]
return do_cleanup.submit(wait_for=test_futures)
In the above does do_cleanup get invoked or does the flow directly go into a failed state?Khuyen Tran
09/06/2022, 2:55 PMBarada Sahu
09/06/2022, 4:15 PMdo_cleanup
is not being invoked if any of the test_futures
fail
Running prefect 2.2.0Khuyen Tran
09/07/2022, 3:02 PMwait_for
argument. If you remove wait_for
, do_cleanup
will run