nailo2c commented on issue #52040:
URL: https://github.com/apache/airflow/issues/52040#issuecomment-3452582552

   Hi, is this issue still exist? I can't reproduce it from my local device on 
the current `main` branch.
   
   Here is my setting:
   
   1. DAG
   ```python
   from airflow import DAG
   from airflow.operators.bash import BashOperator
   import logging
   
   def _on_success(context):
       logging.getLogger().warning(">>> SUCCESS CALLBACK TRIGGERED <<<")
   
   default_args = {
       "owner": "airflow",
       "retries": 0,
   }
   
   with DAG(
       dag_id="git_bundle_success_demo",
       default_args=default_args,
       schedule=None,
       on_success_callback=_on_success,
       catchup=False,
   ) as dag:
       BashOperator(
           task_id="always_succeed",
           bash_command="echo 'simulating success' && exit 0",
       )
   ```
   
   2. Config
   ```python
   dag_bundle_config_list = [{
       "name": "test_git_bundle",
       "classpath": "airflow.providers.git.bundles.git.GitDagBundle",
       "kwargs": {
           "repo_url": "https://github.com/nailo2c/my_repo.git";,
           "tracking_ref": "main"
       }
   }]
   ```
   
   After I ran it, I got logs like the ones below:
   ```console
   root@3b9ea3cba03a:/opt/airflow# cat 
~/airflow/logs/dag_processor/latest/test_git_bundle/example_git_bundle_success_dag.py.log
 | grep "SUCCESS CALLBACK TRIGGERED"
   {"timestamp":"2025-10-26T23:22:00.320640Z","level":"info","event":">>> 
SUCCESS CALLBACK TRIGGERED <<<","logger":"task.stdout"}
   {"timestamp":"2025-10-26T23:26:19.995804Z","level":"warning","event":">>> 
SUCCESS CALLBACK TRIGGERED 
<<<","logger":"root","filename":"example_git_bundle_success_dag.py","lineno":6}
   {"timestamp":"2025-10-26T23:36:36.206576Z","level":"warning","event":">>> 
SUCCESS CALLBACK TRIGGERED 
<<<","logger":"root","filename":"example_git_bundle_success_dag.py","lineno":7}
   ```
   
   Then I committed a change to update the log to `>>> SUCCESS CALLBACK 
TRIGGERED VERSION 2 <<<`. After waiting for the DAG Processor to refresh it, I 
got logs like the ones below:
   ```console
   {"timestamp":"2025-10-26T23:22:00.320640Z","level":"info","event":">>> 
SUCCESS CALLBACK TRIGGERED <<<","logger":"task.stdout"}
   {"timestamp":"2025-10-26T23:26:19.995804Z","level":"warning","event":">>> 
SUCCESS CALLBACK TRIGGERED 
<<<","logger":"root","filename":"example_git_bundle_success_dag.py","lineno":6}
   {"timestamp":"2025-10-26T23:36:36.206576Z","level":"warning","event":">>> 
SUCCESS CALLBACK TRIGGERED 
<<<","logger":"root","filename":"example_git_bundle_success_dag.py","lineno":7}
   {"timestamp":"2025-10-26T23:53:06.247669Z","level":"warning","event":">>> 
SUCCESS CALLBACK TRIGGERED VERSION 2 
<<<","logger":"root","filename":"example_git_bundle_success_dag.py","lineno":7}
   ```
   
   It seems to be working well on my side.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to