instance var

dagster-io · May 23, 2024 · f0b41d9 · f0b41d9
1 parent f7d4185
commit f0b41d9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/python_modules/dagster/dagster/_core/instance/__init__.py b/python_modules/dagster/dagster/_core/instance/__init__.py
@@ -3246,3 +3246,6 @@ def get_asset_check_support(self) -> "AssetCheckInstanceSupport":
             if self.event_log_storage.supports_asset_checks
             else AssetCheckInstanceSupport.NEEDS_MIGRATION
         )
+
+    def backfill_log_storage_enabled(self) -> bool:
+        return False
diff --git a/python_modules/dagster/dagster/_daemon/backfill.py b/python_modules/dagster/dagster/_daemon/backfill.py
@@ -1,5 +1,4 @@
 import logging
-import os
 import sys
 from contextlib import contextmanager
 from typing import Iterable, Mapping, Optional, Sequence, cast
@@ -19,7 +18,7 @@
 def _get_instigation_logger_if_env_var_set(
     instance, backfill_id: str, default_logger: logging.Logger
 ):
-    if os.getenv("STORE_BACKFILL_LOGS", None):
+    if instance.backfill_log_storage_enabled():
         evaluation_time = pendulum.now("UTC")
         log_key = ["backfill", backfill_id, evaluation_time.strftime("%Y%m%d_%H%M%S")]
         with InstigationLogger(