The GitHub Actions job "Tests" on airflow.git has succeeded.
Run started by GitHub user mateuslatrova (triggered by eladkal).

Head commit for run:
62670302caf6699a417b92ed3bdf079005a06c08 / Mateus Latrova <[email protected]>
Fix bug in LivyOperator when its trigger times out

When a LivyOperator was instantiated with deferrable=True and its batch job ran 
for more time than the set execution_timeout, airflow would detect this timeout 
and would cancel the trigger and then try to kill the task with the 'on_kill' 
method.

But that would fail raising an AttributeError because the batch_id attribute 
wouldn't be defined in the constructor method.

>From now on, the LivyTrigger will timeout itself before airflow does it, and 
>it will send an event to the LivyOperator signaling that a timeout happened. 
>This way, the operator can stop the running Livy batch job, and can fail the 
>task instance gracefully.

Report URL: https://github.com/apache/airflow/actions/runs/8640136853

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to