From d850d4e4ca41428523be97bd66a617d9f3963adf Mon Sep 17 00:00:00 2001 From: shima004 Date: Mon, 2 Mar 2026 23:29:23 +0900 Subject: [PATCH 1/2] =?UTF-8?q?feat:=20=E3=82=B9=E3=83=AC=E3=83=83?= =?UTF-8?q?=E3=83=89=E3=81=AE=E3=83=AD=E3=83=83=E3=82=AF=E3=82=92=E8=BF=BD?= =?UTF-8?q?=E5=8A=A0=E3=81=97=E3=80=81=E6=8E=A5=E7=B6=9A=E3=82=B9=E3=83=AC?= =?UTF-8?q?=E3=83=83=E3=83=89=E3=81=AE=E7=AE=A1=E7=90=86=E3=82=92=E6=94=B9?= =?UTF-8?q?=E5=96=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pyproject.toml | 2 +- .../core/launcher/agent_launcher.py | 14 ++++++++++---- uv.lock | 2 +- 3 files changed, 12 insertions(+), 6 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index cbe616f..1f006fd 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "adf_core_python" -version = "0.2.5" +version = "0.2.6" description = "Agent Development Framework for Python" readme = "README.md" authors = [ diff --git a/src/adf_core_python/core/launcher/agent_launcher.py b/src/adf_core_python/core/launcher/agent_launcher.py index a5c119f..daa37c3 100644 --- a/src/adf_core_python/core/launcher/agent_launcher.py +++ b/src/adf_core_python/core/launcher/agent_launcher.py @@ -89,20 +89,26 @@ def launch(self) -> None: gateway_launcher = GatewayLauncher(gateway_host, gateway_port, self.logger) + lock = threading.Lock() connector_thread_list: list[threading.Thread] = [] + for connector in self.connectors: threads = connector.connect( component_launcher, gateway_launcher, self.config, self.loader ) - self.agent_thread_list.extend(threads) - def connect() -> None: + for thread in threads: + thread.daemon = True + + with lock: + self.agent_thread_list.extend(threads) + + def start_connector_threads(threads=threads) -> None: for thread, event in threads.items(): - thread.daemon = True thread.start() event.wait(5) - connector_thread = threading.Thread(target=connect) + connector_thread = threading.Thread(target=start_connector_threads) connector_thread_list.append(connector_thread) connector_thread.start() diff --git a/uv.lock b/uv.lock index 113b158..0f967b1 100644 --- a/uv.lock +++ b/uv.lock @@ -16,7 +16,7 @@ wheels = [ [[package]] name = "adf-core-python" -version = "0.2.3" +version = "0.2.6" source = { editable = "." } dependencies = [ { name = "bitarray" }, From 8127b0d0a7141de2e31fa2c738f430ee54baec4c Mon Sep 17 00:00:00 2001 From: shima004 Date: Mon, 2 Mar 2026 23:32:12 +0900 Subject: [PATCH 2/2] =?UTF-8?q?feat:=20=E3=82=B3=E3=83=8D=E3=82=AF?= =?UTF-8?q?=E3=82=BF=E3=82=B9=E3=83=AC=E3=83=83=E3=83=89=E3=81=AE=E9=96=8B?= =?UTF-8?q?=E5=A7=8B=E6=96=B9=E6=B3=95=E3=82=92=E6=94=B9=E5=96=84=E3=81=97?= =?UTF-8?q?=E3=80=81=E3=82=B9=E3=83=AC=E3=83=83=E3=83=89=E3=81=A8=E3=82=A4?= =?UTF-8?q?=E3=83=99=E3=83=B3=E3=83=88=E3=81=AE=E8=BE=9E=E6=9B=B8=E3=82=92?= =?UTF-8?q?=E4=BD=BF=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/adf_core_python/core/launcher/agent_launcher.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/adf_core_python/core/launcher/agent_launcher.py b/src/adf_core_python/core/launcher/agent_launcher.py index daa37c3..d53d33e 100644 --- a/src/adf_core_python/core/launcher/agent_launcher.py +++ b/src/adf_core_python/core/launcher/agent_launcher.py @@ -103,12 +103,16 @@ def launch(self) -> None: with lock: self.agent_thread_list.extend(threads) - def start_connector_threads(threads=threads) -> None: + def start_connector_threads( + threads: dict[threading.Thread, threading.Event], + ) -> None: for thread, event in threads.items(): thread.start() event.wait(5) - connector_thread = threading.Thread(target=start_connector_threads) + connector_thread = threading.Thread( + target=start_connector_threads, args=(threads,) + ) connector_thread_list.append(connector_thread) connector_thread.start()