Skip to content Skip to sidebar Skip to footer
Showing posts with the label Airflow

How To Use Non-installable Modules From Dag Code?

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?

Python - Attributeerror: 'nonetype' Object Has No Attribute 'execute'

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'

Apache Airflow Dag Cannot Import Local Module

I do not seem to understand how to import modules into an apache airflow DAG definition file. I wou… Read more Apache Airflow Dag Cannot Import Local Module

Unexpected Airflow Behaviour In Dynamic Task Generation

For reasons acceptable to me, I am trying to dynamically generate ExternalTaskSensor tasks with dif… Read more Unexpected Airflow Behaviour In Dynamic Task Generation

Paperboy Throwing Error: Typeerror: The Json Object Must Be Str, Not 'bytes'?

I have installed paperboy using steps given at https://github.com/timkpaine/paperboy.git and execut… Read more Paperboy Throwing Error: Typeerror: The Json Object Must Be Str, Not 'bytes'?

Run Airflow Dag For Each File

So I have this quite nice DAG in airflow which basically runs several analysis steps (implemented a… Read more Run Airflow Dag For Each File