Fixed multithreading error for workers

Author: Seluj78

backend/PyMatcha/utils/orm/_model.py

@@ -1,4 +1,5 @@
 import logging
+import threading
 from copy import deepcopy
 from typing import List
 
@@ -15,7 +16,13 @@ class Model(object):
     Base Model class, all other Models will inherit from this
     """
 
-    db = connection
+    _conn = threading.local()
+
+    @property
+    def db(self):
+        if not hasattr(self._conn, "db"):
+            self._conn.db = pymysql.connect(**database_config)
+        return self._conn.db
 
     # Every model should override this with the correct table name
     table_name = None

backend/PyMatcha/utils/tasks.py

@@ -30,7 +30,7 @@ def setup_periodic_tasks(sender, **kwargs):
     sender.add_periodic_task(
         600, calc_search_min_max.s(), name="Update Minimum and Maximum scores and ages for search every 10 minutes"
     )
-    sender.add_periodic_task(30, random_bot_action.s(), name="200 random bots actions")
+    # sender.add_periodic_task(30, random_bot_action.s(), name="200 random bots actions")
 
 
 @celery.task