diff --git a/pyproject.toml b/pyproject.toml index 8208e84..cd5e83d 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -4,7 +4,7 @@ requires = ["hatchling"] [project] name = "chongming-worker" -version = "0.4.3" +version = "0.4.4" description = "chongming worker" readme = "README.md" requires-python = ">=3.12" diff --git a/src/chongming_worker/runtime.py b/src/chongming_worker/runtime.py index 168fe62..61ab40d 100644 --- a/src/chongming_worker/runtime.py +++ b/src/chongming_worker/runtime.py @@ -997,6 +997,9 @@ async def _managed_worker( """ while True: controller.exit_request = "" + # control_event 为槽位级共享事件:上次 config_set/restart 置位后若不清除, + # 本次重建的副本会立即唤醒 exit_event.wait() 并以 stop 退出,导致副本数 -1。 + controller.control_event.clear() controller.current_worker_id = controller.make_worker_id() controller.reload_cb = reload_cb # 若存在待应用的新配置(config_set 设置),本次重建使用新配置运行