develop

OopenJiuwen-botfix(workflow): loop component with component stream bugfix

4667fc4e创建于 4月29日历史提交

文件	最后提交记录	最后更新时间
conftest.py	feat(callback): implement callback framework with advanced features Implement a comprehensive callback framework for event-driven processing with modular architecture and advanced features. Core Features: - Callback framework with event-driven architecture - Modular design: framework, chain, filters, models, and enums - Trigger decorators for automatic event emission - Filter system: AuthFilter, ParamModifyFilter, ConditionalFilter - Advanced triggers: parallel, conditional, and timeout support - Async generator support for streaming data processing Improvements: - Fix coroutine never awaited warning in decorator - Comprehensive documentation with Mermaid diagrams - Unit tests for callback framework This commit consolidates the initial callback implementation and all subsequent enhancements into a single cohesive feature. Refs: #161 Co-authored-by: alan_cheng<chengshuo5@huawei.com> # message auto-generated for no-merge-commit merge: !329 feat(callback): implement callback framework with advanced features From: @alan_cheng Reviewed-by: @deyang, @yangzequ See merge request: openJiuwen/agent-core!329	3 个月前
test_chain.py	feat(callback): implement callback framework with advanced features Implement a comprehensive callback framework for event-driven processing with modular architecture and advanced features. Core Features: - Callback framework with event-driven architecture - Modular design: framework, chain, filters, models, and enums - Trigger decorators for automatic event emission - Filter system: AuthFilter, ParamModifyFilter, ConditionalFilter - Advanced triggers: parallel, conditional, and timeout support - Async generator support for streaming data processing Improvements: - Fix coroutine never awaited warning in decorator - Comprehensive documentation with Mermaid diagrams - Unit tests for callback framework This commit consolidates the initial callback implementation and all subsequent enhancements into a single cohesive feature. Refs: #161 Co-authored-by: alan_cheng<chengshuo5@huawei.com> # message auto-generated for no-merge-commit merge: !329 feat(callback): implement callback framework with advanced features From: @alan_cheng Reviewed-by: @deyang, @yangzequ See merge request: openJiuwen/agent-core!329	3 个月前
test_emit_sync.py	fix(callback): support pass_args=True in emit_after per_item stream mode The per_item wrappers for both sync and async generators were hardcoding pass_args=False, ignoring the user-provided pass_args parameter. Now the original function arguments are correctly forwarded to the event handler when pass_args=True is set with stream_mode="per_item". Refs: #643 Co-authored-by: alan_cheng<chengshuo5@huawei.com> # message auto-generated for no-merge-commit merge: !829 fix(callback): support pass_args=True in emit_after per_item stream mode From: @alan_cheng Reviewed-by: @SnapeK, @iamcandiceguo See merge request: openJiuwen/agent-core!829	2 个月前
test_enums.py	feat(callback): implement callback framework with advanced features Implement a comprehensive callback framework for event-driven processing with modular architecture and advanced features. Core Features: - Callback framework with event-driven architecture - Modular design: framework, chain, filters, models, and enums - Trigger decorators for automatic event emission - Filter system: AuthFilter, ParamModifyFilter, ConditionalFilter - Advanced triggers: parallel, conditional, and timeout support - Async generator support for streaming data processing Improvements: - Fix coroutine never awaited warning in decorator - Comprehensive documentation with Mermaid diagrams - Unit tests for callback framework This commit consolidates the initial callback implementation and all subsequent enhancements into a single cohesive feature. Refs: #161 Co-authored-by: alan_cheng<chengshuo5@huawei.com> # message auto-generated for no-merge-commit merge: !329 feat(callback): implement callback framework with advanced features From: @alan_cheng Reviewed-by: @deyang, @yangzequ See merge request: openJiuwen/agent-core!329	3 个月前
test_events_scope.py	fix(component): fix the issue where the end component of the main workflow cannot obtain the response content Refs: #590 Co-authored-by: weichenhao<weichenhao3@huawei.com> # message auto-generated for no-merge-commit merge: !741 fix(component):Fix the issue where the end component of the main workflow cannot obtain the response content. From: @weichenhao Reviewed-by: @yangzequ, @alan_cheng See merge request: openJiuwen/agent-core!741	2 个月前
test_filters.py	feat(callback): implement callback framework with advanced features Implement a comprehensive callback framework for event-driven processing with modular architecture and advanced features. Core Features: - Callback framework with event-driven architecture - Modular design: framework, chain, filters, models, and enums - Trigger decorators for automatic event emission - Filter system: AuthFilter, ParamModifyFilter, ConditionalFilter - Advanced triggers: parallel, conditional, and timeout support - Async generator support for streaming data processing Improvements: - Fix coroutine never awaited warning in decorator - Comprehensive documentation with Mermaid diagrams - Unit tests for callback framework This commit consolidates the initial callback implementation and all subsequent enhancements into a single cohesive feature. Refs: #161 Co-authored-by: alan_cheng<chengshuo5@huawei.com> # message auto-generated for no-merge-commit merge: !329 feat(callback): implement callback framework with advanced features From: @alan_cheng Reviewed-by: @deyang, @yangzequ See merge request: openJiuwen/agent-core!329	3 个月前
test_framework_generators.py	feat(callback): add sync function/generator support to emit decorators emit_before, emit_after, emit_around now handle all 4 function types (async plain, async gen, sync plain, sync gen) consistently with transform_io. Sync functions are promoted to async wrappers since _do_trigger requires await. Includes 8 new tests and updated docstrings. Refs: #432	2 个月前
test_framework_hooks.py	fix(agent): trigger agent with session Refs:#568 Co-authored-by: iamcandiceguo<guoqian14@huawei.com> # message auto-generated for no-merge-commit merge: !917 fix(agent): trigger agent with session From: @iamcandiceguo Reviewed-by: @SnapeK, @deyang See merge request: openJiuwen/agent-core!917	2 个月前
test_framework_interrupt.py	feat(callback): add AbortError that propagates out of trigger() AbortError inherits ExecutionError (BaseError hierarchy) and uses StatusCode.CALLBACK_EXECUTION_ABORTED (110600). When raised in a callback: - Stops further callback execution - Propagates out of trigger(); re-raises cause if provided, else re-raises AbortError - Records metrics and circuit-breaker failure (consistent with error semantics) Plain exceptions retain original behaviour: logged and swallowed so subsequent callbacks continue to execute (removed the erroneous raise from that block). Refs: #432	2 个月前
test_framework_metrics.py	feat(callback): implement callback framework with advanced features Implement a comprehensive callback framework for event-driven processing with modular architecture and advanced features. Core Features: - Callback framework with event-driven architecture - Modular design: framework, chain, filters, models, and enums - Trigger decorators for automatic event emission - Filter system: AuthFilter, ParamModifyFilter, ConditionalFilter - Advanced triggers: parallel, conditional, and timeout support - Async generator support for streaming data processing Improvements: - Fix coroutine never awaited warning in decorator - Comprehensive documentation with Mermaid diagrams - Unit tests for callback framework This commit consolidates the initial callback implementation and all subsequent enhancements into a single cohesive feature. Refs: #161 Co-authored-by: alan_cheng<chengshuo5@huawei.com> # message auto-generated for no-merge-commit merge: !329 feat(callback): implement callback framework with advanced features From: @alan_cheng Reviewed-by: @deyang, @yangzequ See merge request: openJiuwen/agent-core!329	3 个月前
test_framework_registration.py	fix(runner): modify on interface and add on_chain Refs:#696 Co-authored-by: iamcandiceguo<guoqian14@huawei.com> # message auto-generated for no-merge-commit merge: !1059 fix(runner): modify on interface and add on_chain From: @iamcandiceguo Reviewed-by: @deyang, @SnapeK See merge request: openJiuwen/agent-core!1059	1 个月前
test_framework_transform_io.py	feat(callback): add event-based transform pipeline with scoped events Introduce scoped event system and transform-specific callback pipeline for modifying function inputs/outputs via events. - Add scoped event support with EventBase class and predefined system events (AgentEvents, WorkflowEvents, etc.) - Add transform_io decorator that enables input/output transformation through event callbacks - Add trigger_transform method that only fires callbacks with callback_type="transform" - Add on_transform convenience decorator for registering transform callbacks - Support both frame-based (per-item) and generator-based transformations - Apply transform pipeline to core classes (Workflow, Tool, BaseModelClient) via metaclasses - Add lazy import for Runner to avoid circular dependencies - Add comprehensive tests for scoped events and transform functionality Refs: #432	2 个月前
test_framework_triggers.py	fix(agent): trigger agent with session Refs:#568 Co-authored-by: iamcandiceguo<guoqian14@huawei.com> # message auto-generated for no-merge-commit merge: !917 fix(agent): trigger agent with session From: @iamcandiceguo Reviewed-by: @SnapeK, @deyang See merge request: openJiuwen/agent-core!917	2 个月前
test_framework_wrap.py	feat(callback): add wrap handler support for explicit call chains Introduce on_wrap and wrap decorators to build explicit WrapHandler chains around functions. Handlers receive call_next as their first argument and control invocation flow, enabling pre/post processing, argument/result transformation, and short-circuiting. Supports both regular functions and generators with dynamic handler lookup through the framework's callback registry. - Add WrapHandler protocol and create_wrap_decorator for static chains - Implement framework.on_wrap() to register handlers with priority - Implement framework.wrap() to apply dynamic handler chains - Add comprehensive tests covering function/generator scenarios Refs: #432	2 个月前
test_metaclass_callbacks.py	fix(workflow): loop component with component stream bugfix Refs: #829 Co-authored-by: iamcandiceguo<guoqian14@huawei.com> # message auto-generated for no-merge-commit merge: !1245 fix(workflow): loop component with component stream bugfix From: @iamcandiceguo Reviewed-by: @deyang, @SnapeK See merge request: openJiuwen/agent-core!1245	1 个月前
test_models.py	feat(callback): implement callback framework with advanced features Implement a comprehensive callback framework for event-driven processing with modular architecture and advanced features. Core Features: - Callback framework with event-driven architecture - Modular design: framework, chain, filters, models, and enums - Trigger decorators for automatic event emission - Filter system: AuthFilter, ParamModifyFilter, ConditionalFilter - Advanced triggers: parallel, conditional, and timeout support - Async generator support for streaming data processing Improvements: - Fix coroutine never awaited warning in decorator - Comprehensive documentation with Mermaid diagrams - Unit tests for callback framework This commit consolidates the initial callback implementation and all subsequent enhancements into a single cohesive feature. Refs: #161 Co-authored-by: alan_cheng<chengshuo5@huawei.com> # message auto-generated for no-merge-commit merge: !329 feat(callback): implement callback framework with advanced features From: @alan_cheng Reviewed-by: @deyang, @yangzequ See merge request: openJiuwen/agent-core!329	3 个月前
test_runner_callback_framework.py	feat(callback): add sync function/generator support to emit decorators emit_before, emit_after, emit_around now handle all 4 function types (async plain, async gen, sync plain, sync gen) consistently with transform_io. Sync functions are promoted to async wrappers since _do_trigger requires await. Includes 8 new tests and updated docstrings. Refs: #432	2 个月前
test_transform_io.py	feat(callback): stack trigger_on_call and emits onto transform_io in metaclasses - trigger() now skips callbacks with callback_type="transform" to prevent double-execution when emits/trigger_on_call and transform_io are stacked - create_trigger_on_call_decorator gains async generator support so it can sit below transform_io in the stream decorator stack - _ToolMeta, _BaseModelClientMeta, _WorkflowMeta now apply three layers: emits(OUT) → transform_io(IN,OUT) → trigger_on_call(IN) → original fn so non-transform callbacks fire with already-transformed input/output - Update test_transform_io.py to reflect new trigger() semantics - Add test_metaclass_callbacks.py (11 tests) covering stacking behavior for Tool, Workflow, and BaseModelClient invoke/stream paths Refs: #432	2 个月前