fix:import

Author: cunla

scheduler/models/task.py

@@ -326,8 +326,9 @@ def _schedule_time(self) -> datetime:
 
     def to_dict(self) -> Dict:
         """Export model to dictionary, so it can be saved as external file backup"""
+        interval_unit = str(self.interval_unit) if self.interval_unit else None
         res = dict(
-            model=self.task_type,
+            model=str(self.task_type),
             name=self.name,
             callable=self.callable,
             callable_args=[
@@ -354,7 +355,7 @@ def to_dict(self) -> Dict:
             cron_string=getattr(self, "cron_string", None),
             scheduled_time=self._schedule_time().isoformat(),
             interval=getattr(self, "interval", None),
-            interval_unit=getattr(self, "interval_unit", None),
+            interval_unit=interval_unit,
             successful_runs=getattr(self, "successful_runs", None),
             failed_runs=getattr(self, "failed_runs", None),
             last_successful_run=getattr(self, "last_successful_run", None),

scheduler/tests/test_mgmt_cmds.py

@@ -0,0 +1,19 @@
+from django.core.management import call_command
+
+from scheduler.queues import get_queue
+from scheduler.tests.jobs import failing_job
+from scheduler.tests.test_views import BaseTestCase
+from scheduler.tools import create_worker
+from scheduler.tests import test_settings # noqa
+
+
+class DeleteFailedExecutionsTest(BaseTestCase):
+    def test_delete_failed_executions__delete_jobs(self):
+        queue = get_queue("default")
+        call_command("delete_failed_executions", queue="default")
+        queue.enqueue(failing_job)
+        worker = create_worker("default")
+        worker.work(burst=True)
+        self.assertEqual(1, len(queue.failed_job_registry))
+        call_command("delete_failed_executions", queue="default")
+        self.assertEqual(0, len(queue.failed_job_registry))