refactor(utils/context): remove the dataset_alias_events deduplicatio…

…n in OutletEventAccessor handle the deduplication in taskinstance all at once
apache · Sep 12, 2024 · 35c5651 · 35c5651
1 parent e8176b7
commit 35c5651
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/airflow/utils/context.py b/airflow/utils/context.py
@@ -193,8 +193,7 @@ def add(self, dataset: Dataset | str, extra: dict[str, Any] | None = None) -> No
         event = DatasetAliasEvent(
             source_alias_name=dataset_alias_name, dest_dataset_uri=dataset_uri, extra=extra or {}
         )
-        if event not in self.dataset_alias_events:
-            self.dataset_alias_events.append(event)
+        self.dataset_alias_events.append(event)
 
 
 class OutletEventAccessors(Mapping[str, OutletEventAccessor]):