已合并
重构回合 #351
qianli创建于 6月29日
重构回合 #351
已合并
Pull Request已成功合入, 合并人@张雅晴
（感谢 qianli 的贡献）openJiuwen-bot
6月29日 评论：
6月29日 评论：
欢迎来到 openJiuwen 社区
Hey @qian-li1126 , 感谢你对社区的贡献.
机器人使用手册
有关指令的使用，可以点击 此处 查看详情。开发人员可以在每个PR或Issue下方评论特定指令来触发机器人任务。
applications/a2a_service/tests/api/test_dispatch_route_edges.py
@@ -0,0 +36,4 @@
36+ return self.values.get(key)
37+
38+ async def set_nx(self, key: str, value: str, ex=None): # noqa: ARG002
39+ if self.set_nx_result:
40+ self.values[key] = value
【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：flake8，请Committer检视其合理性。
applications/a2a_service/tests/api/test_dispatch_route_edges.py
@@ -0,0 +48,6 @@
48+ return self.json_values.get(key)
49+
50+ async def set_json(self, key: str, value, ex=None): # noqa: ARG002
51+ self.json_values[key] = value
52+
53+
54+class _TaskStore:
【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：flake8，请Committer检视其合理性。
applications/a2a_service/tests/api/test_dispatch_route_edges.py
@@ -0,0 +107,7 @@
107+ return SimpleNamespace(message=msg)
108+
109+
110+ def format_event(event, *, agent_id, conversation_id, elapsed): # noqa: ARG002
111+ return {"success": True, "custom_rsp_data": {"event": event["type"], "content": "x"}}
112+
113+
114+def _client(channel=None, *, registry=True, executor=None, redis=None, task_store=None):
【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：flake8，请Committer检视其合理性。
6月29日 添加了label：openJiuwen-cla/yes
applications/a2a_service/tests/conftest.py
@@ -19,0 +16,3 @@
16+class _OpenJiuwenStubFinder(importlib.abc.MetaPathFinder, importlib.abc.Loader):
17+ def find_spec(self, fullname, path=None, target=None): # noqa: ARG002
18+ if fullname != "openjiuwen" and not fullname.startswith("openjiuwen."):
19+ return None
【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：flake8，请Committer检视其合理性。
openJiuwen-bot
6月29日 评论：
6月29日 评论：
applications/a2a_service/tests/conftest.py
@@ -19,0 +29,4 @@
29+ return getattr(_m, name)
30+
31+ mod.__getattr__ = _getattr # type: ignore[attr-defined]
32+ mod.__path__ = []
33+ return mod
【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：mypy，请Committer检视其合理性。
applications/a2a_service/tests/conftest.py
@@ -19,0 +50,4 @@
50+ return getattr(_m, attr)
51+
52+ mod.__getattr__ = _getattr # type: ignore[attr-defined]
53+ mod.__path__ = []
54+ sys.modules[name] = mod
【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：mypy，请Committer检视其合理性。
applications/a2a_service/tests/tools/test_flow_control_runner.py
@@ -0,0 +26,5 @@
26+ return len(self._members.get(key, []))
27+
28+ def zrange(self, key: str, start: int, end: int) -> list[str]: # noqa: ARG002
29+ return self._members.get(key, [])
30+
31+ def exists(self, key: str) -> int:
【openlibing.ci】识别到代码检查告警抑制注释，匹配工具：flake8，请Committer检视其合理性。
openJiuwen-bot
6月29日 评论：
6月29日 评论：
6月29日 添加了label：ci-successful
7月2日 修改了pull request 的描述
7月2日 修改了pull request 的描述
7月2日 修改了pull request 的描述
7月2日 关联了issue：[Refactor]: a2a_service的北向channel解耦优化
7月2日 解决了最后一个问题
7月2日 合入了pull request
7月2日 删除了label：ci-successful
What type of PR is this?
/kind
Self-checklist:（请自检，在[ ]内打上x，我们将检视你的完成情况，否则会导致pr无法合入）