Add black

freifunkMUC · Sep 18, 2023 · bceb4b7 · bceb4b7
1 parent 6e35300
commit bceb4b7
Showing 1 changed file with 16 additions and 12 deletions.
diff --git a/wgkex/worker/msg_queue.py b/wgkex/worker/msg_queue.py
@@ -3,18 +3,22 @@
 from queue import Queue
 from wgkex.common import logger
 from wgkex.worker.netlink import link_handler
-from wgkex.worker.netlink import WireGuardClient        
-
-class UniqueQueue(Queue):                                                                                                                                                                                  
-     def put(self, item, block=True, timeout=None):                                                                                                                                                         
-         if item not in self.queue: # fix join bug                                                                                                                                                          
-             Queue.put(self, item, block, timeout)                                                                                                                                                          
-     def _init(self, maxsize):                                                                                                                                                                              
-         self.queue = set()                                                                                                                                                                                 
-     def _put(self, item):                                                                                                                                                                                  
-         self.queue.add(item)                                                                                                                                                                               
-     def _get(self):                                                                                                                                                                                        
-         return self.queue.pop() 
+from wgkex.worker.netlink import WireGuardClient
+
+
+class UniqueQueue(Queue):
+    def put(self, item, block=True, timeout=None):
+        if item not in self.queue:  # fix join bug
+            Queue.put(self, item, block, timeout)
+
+    def _init(self, maxsize):
+        self.queue = set()
+
+    def _put(self, item):
+        self.queue.add(item)
+
+    def _get(self):
+        return self.queue.pop()
 
 
 q = UniqueQueue()