tag update

dagster-io · Nov 27, 2024 · f9c706b · f9c706b
1 parent 1139a80
commit f9c706b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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},