Python Developer

With assistance from this answer https://stackoverflow.com/a/41730510/4200352 I am executing a pyth… Read more Airflow Python Script With Execution_date In Op_kwargs

I am adding airflow to a web application that manually adds a directory containing business logic t… Read more How To Run Airflow With Celeryexecutor On A Custom Docker Image

I am trying to pass the following configuration parameters to Airflow CLI while triggering a dag ru… Read more Accessing Configuration Parameters Passed To Airflow Through Cli

Right now, nodes in my DAG proceeds to the next day's task before the rest of the nodes of that… Read more Is It Possible For Airflow Scheduler To First Finish The Previous Day's Cycle Before Starting The Next?

I have a python DAG Parent Job and DAG Child Job. The tasks in the Child Job should be triggered on… Read more How To Trigger A Dag On The Success Of A Another Dag In Airflow Using Python?

Not able to setup airflow, getting error while 'Initiating Airflow Database' . I am getting… Read more Not Able To Setup Airflow, Getting Error While "initiating Airflow Database"

I am trying to execute a task after 5 minutes from the parent task inside a DAG. DAG : Task 1 ----&… Read more Apache Airflow: Delay A Task For Some Period Of Time

I have 30 individual tasks in a dag, they have no dependencies between each other. The tasks run th… Read more Airflow Run Tasks At Different Times In The Same Dag?