Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
jamiedemaria committed Dec 8, 2023
1 parent 1f3954c commit 9a1ea2e
Showing 1 changed file with 0 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -128,10 +128,6 @@ class AbstractComputeMetaclass(ABCMeta):


class AbstractComputeExecutionContext(ABC, metaclass=AbstractComputeMetaclass):
"""Base class for op context implemented by OpExecutionContext,
and DagstermillExecutionContext.
"""

"""Base class for op context implemented by OpExecutionContext and DagstermillExecutionContext."""

@abstractmethod
Expand Down Expand Up @@ -532,8 +528,6 @@ def consume_events(self) -> Iterator[DagsterEvent]:
If consume_events has not yet been called, this will yield all logged events since the beginning of the op's computation. If consume_events has been called, it will yield all events since the last time consume_events was called. Designed for internal use. Users should never need to invoke this method.
"""
# events = self.execution_properties.events
# self._events = []
yield from self.execution_properties.consume_events()

@public
Expand Down

0 comments on commit 9a1ea2e

Please sign in to comment.