update yield

python_modules/dagster/dagster/_core/execution/context/compute.py

@@ -1725,7 +1725,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: