sync_event_from_callback_succeess.py

from airflow.decorators import dag, task
import pendulum

from airflow_prefect import send_prefect_event_callback


@dag(
    schedule=None,
    start_date=pendulum.datetime(2023, 1, 24, tz="UTC"),
    catchup=False,
    default_args={
        "on_success_callback": send_prefect_event_callback,
        "on_failure_callback": send_prefect_event_callback,
    },
    tags=["prefect"],
)
def sync_event_from_callback_succeess():
    @task()
    def reliable_task():
        print("Reliable task 🚀")

    reliable_task()


sync_event_from_callback_succeess()