Adam Eury01/26/2023, 8:41 PM
It doesn't appear to happen consistently, so it has been difficult to debug. We are currently on Prefect
prefect.exceptions.UpstreamTaskError: Upstream task run 'None' did not reach a 'COMPLETED' state.
Tony Alfonse01/26/2023, 8:42 PM
Adam Eury01/26/2023, 8:46 PM
item_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))
tasks crashed, but the
Crash detected! Execution was interrupted by an unexpected exception.
Zanie01/26/2023, 9:33 PM
Adam Eury01/26/2023, 9:34 PM