Non-transitive sync status

[INTERNAL_BRANCH=sean/non-transitive-sync]
dagster-io · Jul 3, 2024 · 97ea475 · 97ea475
1 parent 6ad59d9
commit 97ea475
Show file tree

Hide file tree

Showing 3 changed files with 145 additions and 264 deletions.
diff --git a/python_modules/dagster/dagster/_core/definitions/data_version.py b/python_modules/dagster/dagster/_core/definitions/data_version.py
@@ -518,18 +518,7 @@ def _get_stale_causes_materialized(self, key: "AssetKeyPartitionKey") -> Iterato
         partition_deps = self._get_partition_dependencies(key=key)
         for dep_key in sorted(partition_deps):
             dep_asset = self.asset_graph.get(dep_key.asset_key)
-            if (
-                self._instance.use_transitive_stale_causes
-                and self._get_status(key=dep_key) == StaleStatus.STALE
-            ):
-                yield StaleCause(
-                    key,
-                    StaleCauseCategory.DATA,
-                    "stale dependency",
-                    dep_key,
-                    self._get_stale_causes(key=dep_key),
-                )
-            elif provenance:
+            if provenance:
                 if not provenance.has_input_asset(dep_key.asset_key):
                     yield StaleCause(
                         key,

diff --git a/python_modules/dagster/dagster/_core/instance/__init__.py b/python_modules/dagster/dagster/_core/instance/__init__.py
@@ -961,10 +961,6 @@ def auto_materialize_use_sensors(self) -> int:
     def global_op_concurrency_default_limit(self) -> Optional[int]:
         return self.get_settings("concurrency").get("default_op_concurrency_limit")
 
-    @property
-    def use_transitive_stale_causes(self) -> bool:
-        return False
-
     # python logs
 
     @property