Changes after review

Author: Вадим Козыревский

examples/streaming_handler_parallel_events.py

@@ -420,6 +420,10 @@ async def main():
     end_time = datetime.now()
     processing_time = (end_time - start_time).total_seconds()
 
+    # Allow fire-and-forget parallel event handlers to finish (EventProcessor
+    # uses create_task when concurrent_event_handle_enable=True and does not await)
+    await asyncio.sleep(0.3)
+
     # Print summary
     logger.info("\n" + "=" * 80)
     logger.info("Processing Summary")
@@ -441,10 +445,6 @@ async def main():
     logger.info("Example completed successfully!")
     logger.info("=" * 80)
 
-    # Allow fire-and-forget parallel event handlers to finish (EventProcessor
-    # uses create_task when concurrent_event_handle_enable=True and does not await)
-    await asyncio.sleep(0.3)
-
     # Verify results: one event-handler invocation per order per handler type
     assert len(results) == len(order_ids)
     assert len(EMAIL_SENT_LOG) == len(order_ids)

src/cqrs/saga/bootstrap.py

@@ -187,7 +187,7 @@ def events_mapper(mapper: cqrs.EventMap) -> None:
 
         # Execute saga (stream() returns AsyncIterator, consumed with async for)
         async for result in mediator.stream(order_context):
-            print(f"Step: {result.step_type.__name__}")
+            print(f"Step: {result.step_result.step_type.__name__}")
 
     Args:
         di_container: DI container (di.Container or CQRSContainer)