important fix

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:

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)

pyproject.toml

@@ -86,7 +86,6 @@ preview = true
 
 [tool.ruff.format]
 quote-style = 'single'
-#skip-magic-trailing-comma = true
 
 [tool.ruff.lint]
 select = [