andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-05-01 07:13:00 +00:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

feat: populate chain fields in event bus emit

Browse Source
This commit is contained in:
Greyson LaLonde
2026-01-21 01:54:04 -05:00
parent f7838fdcb7
commit 29397da144
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lib/crewai/src/crewai/events/event_bus.py
View File

@@ -24,10 +24,13 @@ from crewai.events.event_context import (
VALID_EVENT_PAIRS, VALID_EVENT_PAIRS,
get_current_parent_id, get_current_parent_id,
get_enclosing_parent_id, get_enclosing_parent_id,
get_last_event_id,
get_triggering_event_id,
handle_empty_pop, handle_empty_pop,
handle_mismatch, handle_mismatch,
pop_event_scope, pop_event_scope,
push_event_scope, push_event_scope,
set_last_event_id,
) )
from crewai.events.handler_graph import build_execution_plan from crewai.events.handler_graph import build_execution_plan
from crewai.events.types.event_bus_types import ( from crewai.events.types.event_bus_types import (
@@ -360,6 +363,8 @@ class CrewAIEventsBus:
... await asyncio.wrap_future(future) # In async test ... await asyncio.wrap_future(future) # In async test
... # or future.result(timeout=5.0) in sync code ... # or future.result(timeout=5.0) in sync code
""" """
event.previous_event_id = get_last_event_id()
event.triggered_by_event_id = get_triggering_event_id()
event.emission_sequence = get_next_emission_sequence() event.emission_sequence = get_next_emission_sequence()
if event.parent_event_id is None: if event.parent_event_id is None:
event_type_name = event.type event_type_name = event.type
@@ -379,6 +384,7 @@ class CrewAIEventsBus:
else: else:
event.parent_event_id = get_current_parent_id() event.parent_event_id = get_current_parent_id()
set_last_event_id(event.event_id)
event_type = type(event) event_type = type(event)
with self._rwlock.r_locked(): with self._rwlock.r_locked():