Skip to content

Commit

Permalink
change context conditions
Browse files Browse the repository at this point in the history
  • Loading branch information
jamiedemaria committed Sep 26, 2023
1 parent 36a6e61 commit de9f54c
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@
from dagster._core.definitions.step_launcher import StepLauncher
from dagster._core.definitions.time_window_partitions import TimeWindow
from dagster._core.errors import (
DagsterInvalidDefinitionError,
DagsterInvalidPropertyError,
DagsterInvariantViolationError,
)
Expand Down Expand Up @@ -1722,6 +1723,7 @@ def log_event(self, event: UserEvent) -> None:
def get_asset_provenance(self, asset_key: AssetKey) -> Optional[DataProvenance]:
return self._op_execution_context.get_asset_provenance(asset_key)


def build_execution_context(
step_context: StepExecutionContext,
) -> Union[OpExecutionContext, AssetExecutionContext]:
Expand All @@ -1735,6 +1737,7 @@ def build_execution_context(
op AssetExecutionContext Error - we cannot init an AssetExecutionContext w/o an AssetsDefinition
op OpExecutionContext OpExecutionContext
op None OpExecutionContext
For ops in graph-backed assets
step type annotation result
op AssetExecutionContext AssetExecutionContext
Expand Down

0 comments on commit de9f54c

Please sign in to comment.