Javier Ochoa
12/22/2022, 8:22 PMwith Flow(
FLOW_NAME,
run_config=UniversalRun(labels=LABELS),
terminal_state_handler=workflow_terminal_state_handler,
) as flow:
file_list = list_unprocessed_files(var)
dataframes = get_dataframes.map(file_list)
dataframes = filter_dataframe.map(
dataframes, resource_type_name=unmapped(var)
)
# this is the final task
print_process_summary_log()