Nimesh Kumar
02/24/2023, 12:24 PMef start_inferencing(my_param, file_path):
job_id = my_param
algo_id = "402"
res_1 = generate_uuid.submit(algo_id, job_id)
call_on_failure_if_failed(res_1)
res_2 = get_file.submit(file_path)
call_on_failure_if_failed(res_2)
res_4 = choose_valid_file.submit(prev_task=res_2)
call_on_failure_if_failed(res_4)
res_5 = prepare_request_upload.submit(prev_task=res_4)
call_on_failure_if_failed(res_5)
res_6 = send_data_request.submit(prev_task=res_5)
call_on_failure_if_failed(res_6)
res_7 = prepare_predict_request.submit(prev_task=res_6)
call_on_failure_if_failed(res_7)
res_8 = send_predict_request.submit(prev_task=res_7)
call_on_failure_if_failed(res_8)
res_9 = extract_lunit_jobid.submit(prev_task=res_8)
call_on_failure_if_failed(res_9)
res_10 = prepare_fetch.submit(prev_task=res_9)
call_on_failure_if_failed(res_10)
res_11 = fetch_request.submit(prev_task=res_10)
call_on_failure_if_failed(res_11)
if res_11:
res_12 = convert_output.submit(prev_task=res_11)
call_on_failure_if_failed(res_12)
res_13 = zip_file.submit(prev_task=res_12)
call_on_failure_if_failed(res_13)
res_14 = send_to_HGW.submit(prev_task=res_13)
call_on_failure_if_failed(res_14)
else:
pass
if __name__ == "main":
start_inferencing(parameters=dict_)
i want to reun convert_output, zip_file, send to hgw, only when condition is true, else exit.