add timeout to request and fix static analysis

mahdigheidi · Feb 15, 2024 · 0001f47 · 0001f47
1 parent 5b80a5c
commit 0001f47
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka_server/broker/file/indexer.py b/kafka_server/broker/file/indexer.py
@@ -110,6 +110,6 @@ def send_to_replica(self):
         url = f'{self.replica}/replica/index'
         data = {'partition': self.partition, 'read': self._read, 'sync': self._sync}
         print(data, "to Replica")
-        response = requests.post(url, json=data)
+        response = requests.post(url, json=data, timeout=2)
         if response.status_code != 200:
             raise Exception(f'indexed not yet updated {response}')