Bowrna commented on issue #27614:
URL: https://github.com/apache/airflow/issues/27614#issuecomment-1337724451
```
def fail_case():
raise AirflowFailException('Failure case test for cluster policy')
failure_test = PythonOperator(
task_id='failure_case',
python_callable=fail_case,
# on_failure_callback=on_failure_callback,
)
```
In this case, this is how I have made the task fail. I have added an
exception to fail it and task callback is invoked. DagFileProcessor is also
invoked in this case.
> And if the DFP is killed after callback is executed so that it cannot
record this, it can be executed again most likely. This is the 'at least once'
semantics
I don't understand this point of yours. Could you help me to understand it?
Do you mean to tell it can be executed more than twice too?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
