Remove RQ dependency

Author: cunla

scheduler/tests/test_worker/test_scheduler.py

@@ -1,6 +1,8 @@
 import time
 from datetime import timedelta, datetime
 
+from django.utils import timezone
+
 from scheduler.helpers.tools import create_worker
 from scheduler.models.task import TaskType
 from scheduler.tests.testtools import SchedulerBaseCase, task_factory
@@ -16,12 +18,12 @@ def test_create_worker_with_scheduler__scheduler_started(self):
         self.assertIsNone(worker.scheduler)
 
     def test_scheduler_schedules_tasks(self):
-        task = task_factory(TaskType.ONCE, scheduled_time=datetime.now() + timedelta(milliseconds=40))
+        task = task_factory(TaskType.ONCE, scheduled_time=timezone.now() + timedelta(milliseconds=40))
         self.assertIsNotNone(task.job_name)
         self.assertNotIn(task.job_name, task.rqueue.queued_job_registry)
         self.assertIn(task.job_name, task.rqueue.scheduled_job_registry)
 
-        scheduler = WorkerScheduler([task.rqueue, ], worker_name="test-worker", connection=task.rqueue.connection)
+        scheduler = WorkerScheduler([task.rqueue, ], worker_name="fake-worker", connection=task.rqueue.connection)
         time.sleep(0.5)
         scheduler._acquire_locks()
         scheduler.enqueue_scheduled_jobs()