[GitHub] [airflow] ZouhirSarrar opened a new issue, #23942: Trigger_rule don't work while using task decorator

Thu, 26 May 2022 09:03:55 -0700 


ZouhirSarrar opened a new issue, #23942:
URL: https://github.com/apache/airflow/issues/23942

   ### Apache Airflow version
   
   2.3.0
   
   ### What happened
   
   Hello!
   
   I'm using taskflow api for my dag and was trying to run the last task even 
if the previous task failed, I used `@task(trigger_rule=TriggerRule.ALL_DONE)` 
but i still got the ending task failed too.
   
   <img width="213" alt="image" 
src="https://user-images.githubusercontent.com/38496723/170526480-131e6ed4-e2a0-4711-9328-2326f94885e3.png";>
   
   The UI confirms that I declared the trigger_rule "all_done"
   <img width="218" alt="image" 
src="https://user-images.githubusercontent.com/38496723/170526766-72ba0eb7-2525-4d60-a8c3-ab3dd700d88b.png";>
   
   
   ### What you think should happen instead
   
   _No response_
   
   ### How to reproduce
   
   This is the whole code
   `import logging
   import pendulum
   from airflow.decorators import task, dag
   from airflow.utils.trigger_rule import TriggerRule
   
   
   @dag(
       schedule_interval=None,
       start_date=pendulum.datetime(2021, 5, 10, tz="UTC"),
       catchup=False,
   )
   def taskflow_trigger():
       @task()
       def first_task():
           return "first_task"
   
       @task
       def second_task(value):
           return "second_task"
   
       @task
       def task_to_fail(value):
           data = {"test": 1}
           val = data["not_here"]
           return val
   
       @task(trigger_rule=TriggerRule.ALL_DONE)
       def end(value):
   
           return "yes"
   
       op_1 = first_task()
       op_3 = task_to_fail(op_1)
       op_2 = second_task(op_1)
       end([op_3, op_2])
   
   
   taskflow_trigger = taskflow_trigger()
   `
   
   ### Operating System
   
   "Debian GNU/Linux 11 (bullseye)
   
   ### Versions of Apache Airflow Providers
   
   _No response_
   
   ### Deployment
   
   Docker-Compose
   
   ### Deployment details
   
   _No response_
   
   ### Anything else
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [X] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
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]

Reply via email to