From 5f18f1b59e27f05dafd38425d3dfde79b346c676 Mon Sep 17 00:00:00 2001 From: Wei Lee Date: Mon, 18 Nov 2024 14:05:29 +0800 Subject: [PATCH] feat(task_sdk/asset): expose extract_event_key --- task_sdk/src/airflow/sdk/definitions/asset/metadata.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/task_sdk/src/airflow/sdk/definitions/asset/metadata.py b/task_sdk/src/airflow/sdk/definitions/asset/metadata.py index 23d5b96dc128..088191970396 100644 --- a/task_sdk/src/airflow/sdk/definitions/asset/metadata.py +++ b/task_sdk/src/airflow/sdk/definitions/asset/metadata.py @@ -25,7 +25,7 @@ from airflow.sdk.definitions.asset import Asset, AssetAlias, _sanitize_uri -__all__ = ["Metadata"] +__all__ = ["Metadata", "extract_event_key"] def extract_event_key(value: str | Asset | AssetAlias) -> str: