ferruzzi commented on issue #60927: URL: https://github.com/apache/airflow/issues/60927#issuecomment-3806648886
I think I'm still confused here, I'm not sure we are all talking about the same thing. 1. You create a Dag with a 180 minute deadline using the DAGRUN_QUEUED reference with a callback to send an email 2. You run the Dag and it gets queued at 12:00:00 Scenario 0: All goes well and the Dag successfully finishes before the deadline Expected behavior: The deadline gets pruned as part of the dag run cleanup step when the dag run finishes and nothing happens. Scenario 1: Some task in the Dag fails at 12:05:00 Expected behavior: At some time between 12:05:00 and 12:05:05 that email will be sent because the Dag did not complete before 13:30:00 Scenario 2: You cancel or manually mark it as failed at 12:05:00 Expected behavior: At some time between 12:05:00 and 12:05:05 that email will be sent because the Dag did not complete before 13:30:00 Scenario 3: Some task in the Dag freezes and it is still running at 13:30:00 Expected behavior: At some time between 13:39:00 and 13:30:05 that email will be sent because the Dag did not complete before 13:30:00 Can you confirm which of those aren't what you'd expect, or if it isn't one of those then maybe clarify what you are seeing? -- 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]
