fix: use event_id in queue

Author: gusye1234

drive_flow/core.py

@@ -88,9 +88,11 @@ async def invoke_event(
         max_async_events: Optional[int] = None,
     ) -> dict[str, Any]:
         this_run_ctx: dict[str, InvokeInterCache] = {}
-        queue: list[Tuple[BaseEvent, EventInput]] = [(event, event_input)]
+        queue: list[Tuple[str, EventInput]] = [(event.id, event_input)]
 
-        async def run_event(current_event: BaseEvent, current_event_input: Any):
+        async def run_event(current_event_id: str, current_event_input: Any):
+            current_event = self.get_event_from_id(current_event_id)
+            assert current_event is not None, f"Event {current_event_id} not found"
             result = await current_event.solo_run(current_event_input, global_ctx)
             this_run_ctx[current_event.id] = {
                 "result": result,
@@ -106,7 +108,7 @@ async def run_event(current_event: BaseEvent, current_event_input: Any):
                             results=this_group_returns,
                             behavior=ReturnBehavior.GOTO,
                         )
-                        queue.append((group_marker, build_input_goto))
+                        queue.append((group_marker.id, build_input_goto))
                 elif result.behavior == ReturnBehavior.ABORT:
                     return
             else:
@@ -146,7 +148,7 @@ async def run_event(current_event: BaseEvent, current_event_input: Any):
                             build_input = EventInput(
                                 group_name=group.name, results=this_group_returns
                             )
-                            queue.append((cand_event, build_input))
+                            queue.append((cand_event.id, build_input))
 
         tasks = set()
         try:

readme.md

@@ -69,7 +69,9 @@ In this example, The return of `hello` event will trigger `world` event.
 
 To make an event function, there are few elements:
 
-* Input Signature: must be `(event: EventInput, global_ctx)`. `EventInput` is the returns of the listening groups. `global_ctx` is set by you when invoking events, it can be anything and default to `None`
+* Input Signature: must be `(event: EventInput, global_ctx)`. `EventInput` is the returns of the listening groups. `global_ctx` is set by you when invoking events, it can be anything and default to `None`.
+
+  This [example](./examples/3_use_event_output.py) shows how to get returns from `EventInput` .
 * Make sure you decorate the function with `@default_drive.make_event` or `@default_drive.listen_group([EVENT,...])`
 
 Then, run your workflow from any event:
@@ -78,7 +80,7 @@ Then, run your workflow from any event:
 await default_drive.invoke_event(EVENT, EVENT_INPUT, GLOBAL_CTX)
 ```
 
-Check out [examples](./examples) for more use cases and features!
+Check out [examples](./examples) for more detailed usages and features!
 
 ## Features