Skip to content

Commit cbc0548

Browse files
committed
fix: 接続後の確認応答の送信位置を修正
fix: スレッド待機時間を5秒から1秒に短縮
1 parent f7b31a3 commit cbc0548

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

src/adf_core_python/core/agent/agent.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -282,8 +282,9 @@ def handle_connect_ok(self, msg: Any) -> None:
282282
for key, value in config.data.items():
283283
self.config.set_value(key, value)
284284

285-
self.send_acknowledge(msg.request_id)
286285
self.post_connect()
286+
287+
self.send_acknowledge(msg.request_id)
287288
self.logger.info(
288289
f"Connected to kernel: {self.__class__.__qualname__} (request_id: {msg.request_id}, agent_id: {self.agent_id}, mode: {self._mode})",
289290
request_id=msg.request_id,

src/adf_core_python/core/launcher/agent_launcher.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ def start_connector_threads(
108108
) -> None:
109109
for thread, event in threads.items():
110110
thread.start()
111-
event.wait(5)
111+
event.wait(1)
112112

113113
connector_thread = threading.Thread(
114114
target=start_connector_threads, args=(threads,)

0 commit comments

Comments
 (0)