Adam Eury
01/26/2023, 8:41 PMprefect.exceptions.UpstreamTaskError: Upstream task run 'None' did not reach a 'COMPLETED' state.
It doesn't appear to happen consistently, so it has been difficult to debug. We are currently on Prefect 2.1.1
.Tony Alfonse
01/26/2023, 8:42 PMAdam Eury
01/26/2023, 8:46 PMitem_ids, filepaths = zip(*get_output_filepaths(context.item_ids))
temp_data_items = import_file.map(item_ids, filepaths)
load_futures = load_items_into_lookup.map(temp_data_items, unmapped(lookup_name))
import_file
tasks crashed, but the Run Count
is 0.import_file
tasks is
Crash detected! Execution was interrupted by an unexpected exception.
Zanie
01/26/2023, 9:33 PMAdam Eury
01/26/2023, 9:34 PM