kernel_gate.py

import airflow
from airflow import DAG
from airflow.operators.dagrun_operator import TriggerDagRunOperator

def trigger_payload(context, dag_run_obj):
    dag_run_obj.payload = {"issues": ["issue-1"]}
    return dag_run_obj

# Define the DAG
dag = DAG(
    dag_id='example_trigger_controller_dag',
    default_args={
        "owner": "airflow",
        "start_date": airflow.utils.dates.days_ago(2),
    },
    schedule_interval='@once',
)

trigger = TriggerDagRunOperator(
    task_id='test_trigger_dagrun',
    trigger_dag_id="kernel_links",
    python_callable=trigger_payload,
    dag=dag,
)