Re: [D] How to call an API when I manually marked a state as success in Airflow UI [airflow]

["nidhishkrishnan (via GitHub)" <gi...@apache.org>]

GitHub user nidhishkrishnan edited a discussion: How to call an API when I manually marked a state as success in Airflow UI

I have created custom Airflow operator to trigger some of my api when the job submits. Everything works fine but one problem is in Airflow UI we have an option to mark state as success, when a user manually click and marked state as failed or success I need to call an API in the custom operator

<img width="456" height="177" alt="image" src="https://github.com/user-attachments/assets/ce072dfd-e19b-43e2-8dbd-3550ce6086e9" />

I used multiple ways one was calling on_failure_callback


    def my_success_callback(context):
        task_id = context['task_instance'].task_id
        print(f"Task {task_id} failed manually.")


    tatus_update_job = CraftSparkOperator(
        on_failure_callback=my_success_callback,
        task_id='applitus-update-job',
        conn_id='craft_dev',
: 
: 

another way was calling on_kill method

    def on_kill(self):
        self.log.info("On Kill: Task: %s with invalid task_id was requested to be cancelled.", self.task_id)
        
even the execute function is also not getting invoked when a user manually click and marked state as success in Airflow UI

It works for failed state change but not for success


I am using Airflow 2.10.0

Can someone help me on this


GitHub link: https://github.com/apache/airflow/discussions/60550

----
This is an automatically sent email for commits@airflow.apache.org.
To unsubscribe, please send an email to: commits-unsubscribe@airflow.apache.org