Need help for this. This is on server as the backend. On exception I am using "raise SystemExit(0)", but the flow is not quitting immediately and takes 15 minutes or so for the flow to fail. What is the issue?

@task()
def mainprocess(a):
    global df_single_record
    try:
        for indx in df_data_extracted.index + 1:
            df_single_record = df_data_extracted.iloc[indx - 1:indx]
            converttojson(df_single_record)
            postjsontoqapi(df_json_data)
    except Exception as e:
        logger = get_logger()
        logger.error(str(get_pst_time())
                     + '==========ERROR IN mainprocess() WHILE CONVERTING TO JSON/POSTING TO Q-API: '
                      + str(e))
        raise SystemExit(0)

Hi @S K this is likely not captured by our standard exception handling because

SystemExit

is a reserved exception type https://docs.python.org/3/library/exceptions.html#SystemExit

@Zanie Thanks for the info, can you please show me the piece of code, how to fail the flow using class prefect.engine.signals.FAIL?

Ah sorry, you just import it and raise it like an exception (ie

raise FAIL()

) https://docs.prefect.io/core/concepts/execution.html#state-signals

@Zanie After following the above, I am able to fail the task successfully, but other subsequent tasks are executed which I don't want. I want to fail the complete flow if any of the tasks fails, how to achieve this?

I think you're looking for https://docs.prefect.io/core/concepts/flows.html#key-tasks

No I did not set any custom triggers, tasks are not running in parallel and they run in sequential way

Great!