https://prefect.io logo
Title
n

Nimesh Kumar

02/24/2023, 12:24 PM
Hi I have this flow and i want to run some flows based on condition, but even if the condition is false, rest of the task also execute
ef 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.