From 2b02af60d5da8b35eacec5c39e83b3cbd92e5926 Mon Sep 17 00:00:00 2001 From: zosimovaa Date: Sat, 21 Feb 2026 23:35:16 +0300 Subject: [PATCH] =?UTF-8?q?=D0=A1=D0=B4=D0=B5=D0=BB=D0=B0=D0=BB=20=D1=81?= =?UTF-8?q?=D0=B0=D0=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pyproject.toml | 4 ++-- src/config_manager/v2/core/manager.py | 9 +++++++-- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/pyproject.toml b/pyproject.toml index 0eb0f07..cd46e86 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -4,8 +4,8 @@ build-backend = "setuptools.build_meta" [project] name = "config_manager" -version = "2.1.2" -description = "Изменена логика задания таймаутов ожидания" +version = "2.1.3" +description = "Курсор утомил..." authors = [ { name = "Aleksei Zosimov", email = "lesha.spb@gmail.com" } ] diff --git a/src/config_manager/v2/core/manager.py b/src/config_manager/v2/core/manager.py index b2582d3..505fd99 100644 --- a/src/config_manager/v2/core/manager.py +++ b/src/config_manager/v2/core/manager.py @@ -3,10 +3,12 @@ Запускает воркер и периодическое обновление конфига, поднимает management-сервер и control-канал при наличии настроек.""" from __future__ import annotations +import os import asyncio import logging import time from typing import Any, Optional +import logging from ...v1.log_manager import LogManager from ..control.base import ControlChannel @@ -20,6 +22,7 @@ from ..types import HealthPayload, LifecycleState, ManagementServerSettings from .config_loader import ConfigLoader from .scheduler import WorkerLoop +logger = logging.getLogger(__name__) class ConfigManagerV2: DEFAULT_UPDATE_INTERVAL = 5 @@ -35,8 +38,9 @@ class ConfigManagerV2: """Инициализация подсистем менеджера и состояния рантайма.""" self.path = path self.config: Any = None - self.update_interval = self.DEFAULT_UPDATE_INTERVAL - self.work_interval = self.DEFAULT_WORK_INTERVAL + # Интервалы опроса (минуты): только здесь, в конфиг не пишем + self.update_interval = int(os.environ.get("UPDATE_INTERVAL", self.DEFAULT_UPDATE_INTERVAL)) + self.work_interval = int(os.environ.get("WORK_INTERVAL", self.DEFAULT_WORK_INTERVAL)) self._loader = ConfigLoader(path) self._log_manager = log_manager or LogManager() @@ -123,6 +127,7 @@ class ConfigManagerV2: async def _worker_loop(self) -> None: """Вызывать execute() циклически до запроса остановки.""" + logger.debug(f"Запускаем _worker_loop с интервалом {self.work_interval}") worker = WorkerLoop( execute=self.execute, get_interval=lambda: self.work_interval,