Jackson Maxfield Brown
06/22/2020, 7:30 PMKyle Moon-Wright
06/22/2020, 7:54 PMJackson Maxfield Brown
06/22/2020, 7:58 PMget_minutes_item_file_details
task is has a retry
and a retry_delay
attached so maybe the map "finishes" and sends the signal to the downstream to move on but the downstream checks for all data and sees that there were a couple of failures that are retrying? Just an idea and not sure how the internals of Prefect work too deeply.Kyle Moon-Wright
06/22/2020, 8:08 PMJackson Maxfield Brown
06/22/2020, 8:10 PMKyle Moon-Wright
06/22/2020, 8:14 PMget_minutes_item_file_details
as you mentioned, which recently underwent a refactor to accommodate DFE - especially considering you are using the DaskExecutor
.Jackson Maxfield Brown
06/22/2020, 8:26 PM