Skip to content

Commit

Permalink
remove interface for now
Browse files Browse the repository at this point in the history
  • Loading branch information
jamiedemaria committed Sep 21, 2023
1 parent 9258a58 commit e688144
Showing 1 changed file with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,7 @@
cast,
)

from dagster_ext import IContext

# from dagster_ext import IContext
import dagster._check as check
from dagster._annotations import deprecated, experimental, public
from dagster._core.definitions.asset_check_spec import AssetCheckSpec
Expand Down Expand Up @@ -1279,6 +1278,7 @@ def asset_check_spec(self) -> AssetCheckSpec:
"step_launcher",
"has_events",
"consume_events",
"log_event",
]
)

Expand Down Expand Up @@ -1344,7 +1344,7 @@ def _get_deprecation_kwargs(attr: str):
return deprecation_kwargs


class AssetExecutionContext(OpExecutionContext, IContext):
class AssetExecutionContext(OpExecutionContext):
def __init__(self, op_execution_context: OpExecutionContext) -> None:
self._op_execution_context = check.inst_param(
op_execution_context, "op_execution_context", OpExecutionContext
Expand Down Expand Up @@ -1457,10 +1457,6 @@ def log(self) -> DagsterLogManager:
"""DagsterLogManager: The log manager available in the execution context."""
return self._op_execution_context.log

@public
def log_event(self, event: UserEvent) -> None:
return self._op_execution_context.log_event(event)

@public
@property
def assets_def(self) -> AssetsDefinition:
Expand Down Expand Up @@ -1696,3 +1692,7 @@ def has_events(self) -> bool:
@property
def asset_check_spec(self) -> AssetCheckSpec:
return self._op_execution_context.asset_check_spec

@deprecated(**_get_deprecation_kwargs("log_event"))
def log_event(self, event: UserEvent) -> None:
return self._op_execution_context.log_event(event)

0 comments on commit e688144

Please sign in to comment.