integrations

Apache Airflow Integration

Compile Airflow operator logic for faster DAG execution.

Published May 30, 2026

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)