remove external writing of a step event

Author: adrianlyjak

src/workflows/plugins/dbos.py

@@ -40,6 +40,8 @@ def register(
         and sent via DBOS.send, enabling durable orchestration.
         """
 
+
+
         # DBOS Python supports async workflow functions; we wrap and return replacement.
         # Note: We do not wrap individual step workers here; the control loop retains
         # responsibility for step execution. This can be extended later to split steps

src/workflows/runtime/broker.py

@@ -163,7 +163,6 @@ async def _run_workflow() -> None:
 
                 if exception_raised:
                     # cancel the stream
-                    self.write_event_to_stream(StopEvent())
                     if not result.done():
                         result.set_exception(exception_raised)
             finally: