fix.

mahdigheidi · Feb 15, 2024 · c8977a1 · c8977a1
1 parent 0e3fd29
commit c8977a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka_server/broker/file/sync.py b/kafka_server/broker/file/sync.py
@@ -16,7 +16,7 @@
 class Sync:
     _instances_lock = threading.Lock()
     _sync_lock = threading.Lock()
-    _instances = None
+    _instances = {}
 
     def __new__(cls, partition: str, replica: str):
         if f"{partition}-{replica}" not in  cls._instances: