Airflow Taskflow API pycharm warning
I’m starting out with Airflow and was trying to convert one of the tutorials to TaskFlow.
How to set up airflow alerting so it alerts only on last retry attempt?
My current DAG looks like:
Airflow confuse path_file with Jinja template: Exception rendering Jinja template for task ‘start’, field ‘op_kwargs’
I am encuntering an unexpected behaviour from airflow when trying to pass path of file to tasks.
if any one of the input sensors fail, it should stop at start – DAG should fail
I have a dag where I have a task called start which is a dummy operator . Before the start I have a few input sensors for checking the file . I need to run the DAG for test cases .
Can I use airflow tags to determine if all DAGs with a certain tag has finished running?
I have a number of individual DAGs that are not connected to each other. The one thing that ‘connects’ them are that they are tagged with US_TAG.
In Apache Airflow, how can I exchange data between tasks in different dags, using the Airflow TaskFlow API?
I have 2 dags that look like this (note that the 2nd dag automatically runs after the first – they are linked by an Airflow Dataset). Is there a way for the 2nd dag to retrieve the value returned by the first dag’s push_data task?