diff --git a/frontik/process.py b/frontik/process.py index 56d1a884b..a5670336a 100644 --- a/frontik/process.py +++ b/frontik/process.py @@ -132,7 +132,7 @@ def _start_child(worker_id: int, worker_state: WorkerState, worker_function: Cal os.set_blocking(read_fd, False) os.set_blocking(write_fd, False) - pid = os.fork() # тут чето мне недавали сделать fdopen но мб потомучто я в другом процессе не закрыл + pid = os.fork() if pid == 0: # worker os.close(write_fd) worker_state.is_master = False @@ -235,7 +235,7 @@ def _resend( clients = list(resend_dict.keys()) if log.isEnabledFor(logging.DEBUG): client_ids = ','.join(map(str, clients)) - log.debug('sending upstreams to %s length: %d', client_ids, len(data)) + log.debug('sending data to %s length: %d', client_ids, len(data)) resend_dict.clear() for worker_id in clients: diff --git a/frontik/service_discovery.py b/frontik/service_discovery.py index bc930065c..3de3c64b1 100644 --- a/frontik/service_discovery.py +++ b/frontik/service_discovery.py @@ -250,9 +250,8 @@ def _combine_servers(self, key: str) -> list[Server]: return servers_from_all_dc def update_upstreams(self, upstreams: list[Upstream]) -> None: - with self._upstreams_lock: - for upstream in upstreams: - self._update_upstream(upstream) + for upstream in upstreams: + self._update_upstream(upstream) def _update_upstream(self, upstream: Upstream) -> None: current_upstream = self._upstreams.get(upstream.name) diff --git a/pyproject.toml b/pyproject.toml index ba5543ea3..c40c954dc 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -86,7 +86,6 @@ preview = true [tool.ruff.format] quote-style = 'single' -#skip-magic-trailing-comma = true [tool.ruff.lint] select = [