This is an automated email from the ASF dual-hosted git repository.
vatsrahul1001 pushed a commit to branch v3-4-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 42e1aa8a4df99b7e2c18410cf2ec4de7643389a1
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Nov 6 08:08:06 2026 +0000
[v3-4-test] Fix duplicated asset events when name_prefix_pattern matches
all (#74816) (#76570)
The "~" match-all alias for name_prefix_pattern is transformed into an empty
string, so the truthiness check skipped the join to the asset table while
the
filter still referenced it, and each event was returned once per asset.
(cherry picked from commit 322c178e05b6621b9577e62e66964c1f4c0b590f)
Co-authored-by: Sahil Ray <[email protected]>
Co-authored-by: Henry Chen <[email protected]>
---
airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py | 2 +-
.../tests/unit/api_fastapi/core_api/routes/public/test_assets.py | 2 ++
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git
a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
index 003e880b81d..5025f02eb1f 100644
--- a/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
+++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/public/assets.py
@@ -346,7 +346,7 @@ def get_asset_events(
# The regexp partition-key filter bounds the query runtime automatically
(its dependency applies
# ``apply_regex_query_timeout`` to this request's session), so no explicit
wrapping is needed here.
base_statement = select(AssetEvent)
- if name_pattern.value or name_prefix_pattern.value:
+ if name_pattern.value is not None or name_prefix_pattern.value is not None:
base_statement = base_statement.join(AssetModel, AssetEvent.asset_id
== AssetModel.id)
assets_event_select, total_entries = paginated_select(
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
index d9ba3d5b9b6..bb6d55ac096 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
@@ -1365,6 +1365,8 @@ class TestGetAssetEvents(TestAssets):
({"name_prefix_pattern": "simple1"}, 1),
({"name_prefix_pattern": "simple"}, 2),
({"name_prefix_pattern": "nonexistent"}, 0),
+ ({"name_prefix_pattern": "~"}, 2),
+ ({"name_pattern": ""}, 2),
],
)
@provide_session
