andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-09-22 10:56:50 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fix(experimental): satisfy mypy on the /btw command installer

Browse Source 
Cast the wrapped route_turn return, type the class wrapper as Any, and
overload enable_btw_commands for class vs instance targets.

Co-authored-by: Lorenze Jay <lorenzejay@users.noreply.github.com>
This commit is contained in:
Cursor Agent
2026-08-31 07:03:15 +00:00
parent 13bdd8fc23
commit c60e4a1218
1 changed files with 16 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
lib/crewai/src/crewai/experimental/conversation_commands/addon.py
View File

@@ -93,7 +93,7 @@ def _wrap_route_turn(original: Callable[..., Any]) -> Callable[..., Any]:
forced = get_btw_steering(self).consume_forced_route()
if forced:
return forced
return original(self, context)
return cast(str | None, original(self, context))
return route_turn
@@ -114,16 +114,12 @@ def _wrap_resolve_system_prompt(original: Callable[..., Any]) -> Callable[..., A
return _resolve_system_prompt
def _wrap_class(cls: type[T]) -> type[T]:
cls.handle_turn = _wrap_handle_turn(cls.handle_turn) # type: ignore[attr-defined]
cls.stream_turn = _wrap_stream_turn(cls.stream_turn) # type: ignore[attr-defined]
cls.route_turn = _wrap_route_turn(cls.route_turn) # type: ignore[attr-defined]
cls.build_router_context = _wrap_build_router_context( # type: ignore[attr-defined]
cls.build_router_context
)
cls._resolve_system_prompt = _wrap_resolve_system_prompt( # type: ignore[attr-defined]
cls._resolve_system_prompt
)
def _wrap_class(cls: Any) -> Any:
cls.handle_turn = _wrap_handle_turn(cls.handle_turn)
cls.stream_turn = _wrap_stream_turn(cls.stream_turn)
cls.route_turn = _wrap_route_turn(cls.route_turn)
cls.build_router_context = _wrap_build_router_context(cls.build_router_context)
cls._resolve_system_prompt = _wrap_resolve_system_prompt(cls._resolve_system_prompt)
setattr(cls, ENABLED_ATTR, True)
return cls
@@ -154,6 +150,14 @@ def _wrap_instance(flow: T) -> T:
return flow
@overload
def enable_btw_commands(target: type[T]) -> type[T]: ...
@overload
def enable_btw_commands(target: T) -> T: ...
def enable_btw_commands(target: T) -> T:
"""Install ``/btw`` interjections on a Flow class or instance.
@@ -163,7 +167,7 @@ def enable_btw_commands(target: T) -> T:
if _already_enabled(target):
return target
if isinstance(target, type):
return _wrap_class(cast(type[T], target))
return cast(T, _wrap_class(target))
return _wrap_instance(target)