It does not seem to complain anymore, but it does not complain any less

Signed-off-by: bghira <bghira@users.github.com>

discord_tron_master/classes/worker.py

@@ -66,11 +66,7 @@ async def process_jobs(self):
                 logging.error(f"An error occurred while processing jobs for worker {self.worker_id}: {e}")
                 await asyncio.sleep(1)  # Use 'await' for asynchronous sleep
 
-    def start(self):
-        # Use 'asyncio.create_task' to run the 'process_jobs' coroutine
-        self.worker_task = asyncio.create_task(self.process_jobs())
-
-    def monitor_worker(self):
+    async def monitor_worker(self):
         logging.debug(f"Beginning worker monitoring for worker {self.worker_id}")
         while True:
             if self.worker_task is None or self.worker_task.done() and not self.terminate:
@@ -80,8 +76,9 @@ def monitor_worker(self):
                 logging.info("Worker is set to exit, and the time has come.")
                 break
             # Sleep for a while before checking again
-            time.sleep(10)
+            await asyncio.sleep(10)
 
-    def start_monitoring_thread(self):
-        self.monitor_thread = threading.Thread(target=self.monitor_worker)
-        self.monitor_thread.start()
+    async def start_monitoring(self):
+        # Use 'asyncio.create_task' to run the 'process_jobs' and 'monitor_worker' coroutines
+        self.worker_task = asyncio.create_task(self.process_jobs())
+        self.monitor_task = asyncio.create_task(self.monitor_worker())

discord_tron_master/classes/worker_manager.py

@@ -105,7 +105,7 @@ async def register(self, payload: Dict[str, Any]) -> Dict:
         worker = self.register_worker(worker_id, supported_job_types, hardware_limits, hardware)
         self.queue_manager.register_worker(worker_id, supported_job_types)
         worker.set_job_queue(self.queue_manager.queue_by_worker(worker))
-        worker.start_monitoring_thread()
+        await worker.start_monitoring()  # Use 'await' to call the async 'start_monitoring' method
         return {"success": True, "result": "Worker " + str(worker_id) + " registered successfully"}
 
     async def unregister(self, payload: Dict[str, Any]) -> Dict: