From 842b47018f0908ed46d7aad7d010124f1e99ccfa Mon Sep 17 00:00:00 2001 From: JamieDeMaria Date: Tue, 5 Dec 2023 19:44:24 -0500 Subject: [PATCH] update yield --- .../dagster/dagster/_core/execution/context/compute.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python_modules/dagster/dagster/_core/execution/context/compute.py b/python_modules/dagster/dagster/_core/execution/context/compute.py index 6bac3e12231ce..37915f1ae2334 100644 --- a/python_modules/dagster/dagster/_core/execution/context/compute.py +++ b/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: