From 9c5fa62485d0fd9f20bbb100d56c5f83eaf67272 Mon Sep 17 00:00:00 2001 From: Ben Pankow Date: Mon, 9 Sep 2024 16:26:23 -0700 Subject: [PATCH] [dagster-airlift] display airflow kind on assets when no recorded migration state (#24336) ## Summary Gives us kind tags on airflow assets even before migration starts (when this status is empty) --- .../dagster_airlift/core/airflow_cacheable_assets_def.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/experimental/dagster-airlift/dagster_airlift/core/airflow_cacheable_assets_def.py b/examples/experimental/dagster-airlift/dagster_airlift/core/airflow_cacheable_assets_def.py index 5e75cd218eaf5..023497c711bd6 100644 --- a/examples/experimental/dagster-airlift/dagster_airlift/core/airflow_cacheable_assets_def.py +++ b/examples/experimental/dagster-airlift/dagster_airlift/core/airflow_cacheable_assets_def.py @@ -380,7 +380,7 @@ def construct_assets_with_task_migration_info_applied( # metadata fields from the original spec it was built from after deserializing. cacheable_specs.task_asset_specs[spec.key].to_asset_spec( additional_metadata=spec.metadata, - additional_tags=airflow_kind_dict() if overall_migration_status == "False" else {}, + additional_tags=airflow_kind_dict() if overall_migration_status != "True" else {}, ) for spec in specs ]