Lee-W commented on issue #31743: URL: https://github.com/apache/airflow/issues/31743#issuecomment-1598786020
Hi @zoid-w, thank you for your reproducing steps. It's really helpful for me to track this issue Hi @pauloventurab, it appears that the root cause of the problem can be traced back to these [lines](https://github.com/apache/airflow/blob/1d564adc1c5dc31d0c9717d608250b60f9742acb/airflow/jobs/triggerer_job_runner.py#L711-L713). Restarting the `airflow trigger` is necessary in order to ensure that any changes made to it are properly reflected. I am uncertain if we wish to consistently reload triggers, but I have created a draft pull request https://github.com/apache/airflow/pull/32032 to showcase my current concept and waiting for feedback As for what you suggested in > What you think should happen instead > > I think it should work, and maybe also simplify the apply_function to the function name without the module importation, just the function inside the dag, could be a task as well. This might not be something we can do for now as we cannot pass a `Callable` into the trigger. -- 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]
