diff --git a/django_dbq/management/commands/delete_old_jobs.py b/django_dbq/management/commands/delete_old_jobs.py
index 15d4cc8..1bdc072 100644
--- a/django_dbq/management/commands/delete_old_jobs.py
+++ b/django_dbq/management/commands/delete_old_jobs.py
@@ -6,6 +6,15 @@ class Command(BaseCommand):
 
     help = "Delete old jobs"
 
+    def add_arguments(self, parser):
+        parser.add_argument(
+            "--hours",
+            help="Delete jobs older than this many hours",
+            default=None,
+            required=False,
+            type=int,
+        )
+
     def handle(self, *args, **options):
-        Job.objects.delete_old()
+        Job.objects.delete_old(hours=options["hours"])
         self.stdout.write("Deleted old jobs")
diff --git a/django_dbq/models.py b/django_dbq/models.py
index 3e12289..d93a05b 100644
--- a/django_dbq/models.py
+++ b/django_dbq/models.py
@@ -15,7 +15,7 @@
 logger = logging.getLogger(__name__)
 
 
-DELETE_JOBS_AFTER_HOURS = 24
+DEFAULT_DELETE_JOBS_AFTER_HOURS = 24
 
 
 class JobManager(models.Manager):
@@ -49,9 +49,9 @@ def get_ready_or_none(self, queue_name, max_retries=3):
                     retries_left,
                 )
 
-    def delete_old(self):
+    def delete_old(self, hours=None):
         """
-        Delete all jobs older than DELETE_JOBS_AFTER_HOURS
+        Delete all jobs older than hours, or DEFAULT_DELETE_JOBS_AFTER_HOURS
         """
         delete_jobs_in_states = [
             Job.STATES.FAILED,
@@ -59,7 +59,7 @@ def delete_old(self):
             Job.STATES.STOPPING,
         ]
         delete_jobs_created_before = timezone.now() - datetime.timedelta(
-            hours=DELETE_JOBS_AFTER_HOURS
+            hours=hours or DEFAULT_DELETE_JOBS_AFTER_HOURS
         )
         logger.info(
             "Deleting all job in states %s created before %s",
diff --git a/django_dbq/tests.py b/django_dbq/tests.py
index 5ed868c..ad376cd 100644
--- a/django_dbq/tests.py
+++ b/django_dbq/tests.py
@@ -371,3 +371,17 @@ def test_delete_old_jobs(self):
         self.assertEqual(Job.objects.count(), 2)
         self.assertTrue(j4 in Job.objects.all())
         self.assertTrue(j5 in Job.objects.all())
+
+    def test_delete_old_jobs_with_custom_hours_argument(self):
+        j1 = Job.objects.create(name="testjob", state=Job.STATES.COMPLETE)
+        j1.created = timezone.now() - timedelta(days=5)
+        j1.save()
+
+        j2 = Job.objects.create(name="testjob", state=Job.STATES.COMPLETE)
+        j2.created = timezone.now() - timedelta(days=3)
+        j2.save()
+
+        Job.objects.delete_old(hours=24 * 4)
+
+        self.assertEqual(Job.objects.count(), 1)
+        self.assertTrue(j2 in Job.objects.all())