Apache Airflow Integration

May 30, 2026 | 5 min read

Custom Operator

from airflow import DAG
from airflow.operators.python import PythonOperator

def transform(**context):
    data = context["ti"].xcom_pull(task_ids="extract")
    return compiled_transform(data)

with DAG("pyvorin_pipeline") as dag:
    t1 = PythonOperator(task_id="transform", python_callable=transform)