zenonsk commented on issue #52040: URL: https://github.com/apache/airflow/issues/52040#issuecomment-3521179499
We are experiencing the same issue as @liyude-tw. We are running 3.1.2 on python 3.11 and are using a GitDagBundle set up to track a specific branch. Looking at the code, it seems like in airflow-core/src/airflow/dag_processing/manager.py, in _add_callback_to_queue, we are missing a call to initialize() on the instantiated dag bundle to ensure the GitDagBundle clones the version to the /versions/<commit> path. Since this is the only place in the code where get_bundle is called with a version supplied, the dag code cannot have been cloned to the version sub-directory before, yet the processor expects the dag to be in the /versions/<commit> directory. -- 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]
