jason810496 commented on code in PR #74249:
URL: https://github.com/apache/airflow/pull/74249#discussion_r4194657426
##########
airflow-core/src/airflow/dag_processing/dagbag.py:
##########
@@ -327,17 +327,21 @@ def _process_definition(
self.captured_warnings.pop(fileloc, None)
self._import_warnings.pop(fileloc, None)
- self.dag_source_codes.pop(fileloc, None)
+ # Keyed by dag_id, not fileloc: a bundle can embed several Dags' own
source under one
+ # fileloc, so a stale entry is found by which dag_ids this fileloc
previously bagged.
+ for dag_id, dag in list(self.dags.items()):
Review Comment:
I will track a issue for this item.
Just merged the PR as my Go SDK DagImporter will need the core change of
this PR as well.
--
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]
