Nimesh Kumar
02/10/2023, 9:07 AMTadej Svetina
02/10/2023, 12:35 PMNimesh Kumar
02/10/2023, 12:38 PM@flow(name="Inferencing")
def start_inferencing(my_param, file_path):
print(">>>>>>>>>>>>>>>>>>>>>>>>>>>")
print(my_param, file_path)
print(">>>>>>>>>>>>>>>>>>>>>>>>>>>")
res_1 = generate_jobID.submit(my_param)
call_on_failure_if_failed(res_1)
res_2 = get_file.submit(prev_task = file_path)
call_on_failure_if_failed(res_2)
res_3 = unzip.submit(prev_task = res_2)
call_on_failure_if_failed(res_2)
res_6 = add_pvt_tag.submit(prev_task = res_3)
call_on_failure_if_failed(res_6)
res_5 = send_data(prev_task = res_6)
#call_on_failure_if_failed(res_5)
if __name__ == "main":
start_inferencing()
Tadej Svetina
02/10/2023, 12:40 PMNimesh Kumar
02/10/2023, 12:44 PMTadej Svetina
02/10/2023, 1:33 PMNimesh Kumar
02/10/2023, 1:35 PMTadej Svetina
02/10/2023, 1:37 PMNimesh Kumar
02/10/2023, 1:38 PM