potiuk commented on issue #27614: URL: https://github.com/apache/airflow/issues/27614#issuecomment-1337055868
They are executed - but not in task because task is not there in this case. Callbacks for tasks that were 'killed' are executed in DagFileProcessor normally. But again - the distribution happens, so it is very likely that there are cases where the callbacks are execute in both - task and DFP because the DFP 'thonks' the callback was not executed in the task..this is one of the cases where callbacks might be executed more than once. 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 -- 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]
