important fix

hhru · Mar 18, 2024 · 9a9c3db · 9a9c3db
1 parent 253d949
commit 9a9c3db
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git 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

diff --git 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)