diff --git a/python_modules/dagster/dagster/_core/execution/context/compute.py b/python_modules/dagster/dagster/_core/execution/context/compute.py
index 6c084c7e4af74..0984dc644c689 100644
--- a/python_modules/dagster/dagster/_core/execution/context/compute.py
+++ b/python_modules/dagster/dagster/_core/execution/context/compute.py
@@ -1720,7 +1720,7 @@ 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.
         """
-        return self.op_execution_context.consume_events()
+        yield from self.op_execution_context.consume_events()
 
     @public
     def log_event(self, event: UserEvent) -> None: