Basic Airflow in Python
Airflow: platform to program workflows.
DAG: workflow made up of tasks with dependencies.
Define a DAG in Python:
from airflow.models import DAG
from datetime import datetime
#create a default arguments dictionary (optional)
default_arguments = {
...
massyfigini.hashnode.dev6 min read