Python Courses, Training, and Tutorials

Is there a neater way to get the complete URI from a Postgres hook? .get_uri() doesn't include … Read more Retrieve Full Connection Uri From Airflow Postgres Hook

I am exploring Airflow to be used as a cron so that I could use its other features while setting up… Read more Airflow Cron Expression Is Not Scheduling Dag Properly

I have a Git repository which (among other things) holds Airflow DAGs in airflow directory. I have … Read more How To Use Non-installable Modules From Dag Code?

Using Airflow worker and webserver/scheduler as a Docker images running on Kubernetes Engine on EC2… Read more Airflow Worker - Connection Broken: Incompleteread(0 Bytes Read)

I am trying to run a python script that logs into Amazon Redshift DB and then execute a SQL command… Read more Python - Attributeerror: 'nonetype' Object Has No Attribute 'execute'

I'm trying to model my ETL jobs with Airflow. All jobs have kind of the same structure: Extrac… Read more Etl Model With Dags And Tasks