Remove RQ dependency

Author: cunla

scheduler/helpers/tools.py

@@ -71,8 +71,7 @@ def create_worker(*queue_names: str, **kwargs) -> Worker:
         kwargs["name"] = _calc_worker_name(existing_worker_names)
     if kwargs["name"] in existing_worker_names:
         raise ValueError(f"Worker {kwargs['name']} already exists")
-
     kwargs["name"] = kwargs["name"].replace("/", ".")
-
+    kwargs.setdefault("with_scheduler", False)
     worker = Worker(queues, connection=queues[0].connection, **kwargs)
     return worker

scheduler/redis_models/base.py

@@ -184,7 +184,6 @@ def save(self, connection: ConnectionType) -> None:
             connection.hdel(self._key, *none_values)
         mapping = {k: v for k, v in mapping.items() if v is not None}
         if mapping:
-            logger.debug(f"Saving {self._key}")
             connection.hset(self._key, mapping=mapping)
         self._dirty_fields = set()
         self._save_all = False

scheduler/tests/test_worker/test_worker_creation.py

@@ -35,8 +35,9 @@ def test_create_worker__with_name_containing_slash(self):
     def test_create_worker__scheduler_interval(self):
         prev = settings.SCHEDULER_CONFIG.SCHEDULER_INTERVAL
         settings.SCHEDULER_CONFIG.SCHEDULER_INTERVAL = 1
-        worker = create_worker("default", name="test", burst=True)
+        worker = create_worker("default", name="test", burst=True, with_scheduler=True)
         worker.bootstrap()
         self.assertEqual(worker.name, "test")
         self.assertEqual(worker.scheduler.interval, 1)
         settings.SCHEDULER_CONFIG.SCHEDULER_INTERVAL = prev
+        worker.teardown()