fix: remove useless lock from EventWriteThread

DataShades · Nov 7, 2024 · 8e5b4df · 8e5b4df
1 parent afd896e
commit 8e5b4df
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/ckanext/event_audit/plugin.py b/ckanext/event_audit/plugin.py
@@ -20,7 +20,6 @@ def __init__(self, queue: queue.Queue[types.Event]):
         threading.Thread.__init__(self)
         self.queue = queue
         self.data = types.ThreadData(last_push=datetime.now(tz.utc), events=[])
-        self.lock = threading.Lock()
 
     def run(self):
         while True:
@@ -37,13 +36,12 @@ def run(self):
             ) >= config.get_batch_size() or self._is_time_to_push(
                 self.data["last_push"]
             ):
-                with self.lock:
-                    repo = utils.get_active_repo()
+                repo = utils.get_active_repo()
 
-                    repo.write_events(self.data["events"])
+                repo.write_events(self.data["events"])
 
-                    self.data["events"] = []
-                    self.data["last_push"] = datetime.now(tz.utc)
+                self.data["events"] = []
+                self.data["last_push"] = datetime.now(tz.utc)
 
             self.queue.task_done()