From f810d43762e2b73d74259445754098d3c8c97781 Mon Sep 17 00:00:00 2001 From: JamieDeMaria Date: Mon, 25 Nov 2024 17:18:06 -0500 Subject: [PATCH] tag update --- .../dagster/dagster/_core/execution/asset_backfill.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python_modules/dagster/dagster/_core/execution/asset_backfill.py b/python_modules/dagster/dagster/_core/execution/asset_backfill.py index 0dba00d5635d5..846d9dcc752aa 100644 --- a/python_modules/dagster/dagster/_core/execution/asset_backfill.py +++ b/python_modules/dagster/dagster/_core/execution/asset_backfill.py @@ -61,7 +61,7 @@ from dagster._core.storage.tags import ( ASSET_PARTITION_RANGE_END_TAG, ASSET_PARTITION_RANGE_START_TAG, - AUTO_RETRY_RUN_ID, + AUTO_RETRY_RUN_ID_TAG, BACKFILL_ID_TAG, PARTITION_NAME_TAG, WILL_RETRY_TAG, @@ -978,7 +978,7 @@ def backfill_is_complete( if any( [ get_boolean_tag_value(run.tags.get(WILL_RETRY_TAG), False) - and run.tags.get(AUTO_RETRY_RUN_ID) is None + and run.tags.get(AUTO_RETRY_RUN_ID_TAG) is None for run in instance.get_runs( filters=RunsFilter( tags={BACKFILL_ID_TAG: backfill_id},