Adds a 'minutes' option to the scheduler

django_q/cluster.py

@@ -440,7 +440,9 @@ def scheduler(list_key=Conf.Q_LIST):
             # set up the next run time
             if not s.schedule_type == s.ONCE:
                 next_run = arrow.get(s.next_run)
-                if s.schedule_type == s.HOURLY:
+                if s.schedule_type == s.MINUTES:
+                    next_run = next_run.replace(minutes=+(s.minutes or 1))
+                elif s.schedule_type == s.HOURLY:
                     next_run = next_run.replace(hours=+1)
                 elif s.schedule_type == s.DAILY:
                     next_run = next_run.replace(days=+1)

django_q/migrations/0006_auto_20150805_1817.py

@@ -0,0 +1,24 @@
+# -*- coding: utf-8 -*-
+from __future__ import unicode_literals
+
+from django.db import models, migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('django_q', '0005_auto_20150718_1506'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='schedule',
+            name='minutes',
+            field=models.PositiveSmallIntegerField(help_text='Number of minutes for the Minutes type', blank=True, null=True),
+        ),
+        migrations.AlterField(
+            model_name='schedule',
+            name='schedule_type',
+            field=models.CharField(max_length=1, choices=[('O', 'Once'), ('I', 'Minutes'), ('H', 'Hourly'), ('D', 'Daily'), ('W', 'Weekly'), ('M', 'Monthly'), ('Q', 'Quarterly'), ('Y', 'Yearly')], default='O', verbose_name='Schedule Type'),
+        ),
+    ]

django_q/models.py

@@ -137,6 +137,7 @@ class Schedule(models.Model):
     args = models.TextField(null=True, blank=True, help_text=_("e.g. 1, 2, 'John'"))
     kwargs = models.TextField(null=True, blank=True, help_text=_("e.g. x=1, y=2, name='John'"))
     ONCE = 'O'
+    MINUTES = 'I'
     HOURLY = 'H'
     DAILY = 'D'
     WEEKLY = 'W'
@@ -145,6 +146,7 @@ class Schedule(models.Model):
     YEARLY = 'Y'
     TYPE = (
         (ONCE, _('Once')),
+        (MINUTES, _('Minutes')),
         (HOURLY, _('Hourly')),
         (DAILY, _('Daily')),
         (WEEKLY, _('Weekly')),
@@ -153,6 +155,8 @@ class Schedule(models.Model):
         (YEARLY, _('Yearly')),
     )
     schedule_type = models.CharField(max_length=1, choices=TYPE, default=TYPE[0][0], verbose_name=_('Schedule Type'))
+    minutes = models.PositiveSmallIntegerField(null=True, blank=True,
+                                               help_text=_('Number of minutes for the Minutes type'))
     repeats = models.SmallIntegerField(default=-1, verbose_name=_('Repeats'), help_text=_('n = n times, -1 = forever'))
     next_run = models.DateTimeField(verbose_name=_('Next Run'), default=timezone.now, null=True)
     task = models.CharField(max_length=100, null=True, editable=False)

django_q/tasks.py

@@ -66,6 +66,7 @@ def schedule(func, *args, **kwargs):
     name = kwargs.pop('name', None)
     hook = kwargs.pop('hook', None)
     schedule_type = kwargs.pop('schedule_type', Schedule.ONCE)
+    minutes = kwargs.pop('minutes', None)
     repeats = kwargs.pop('repeats', -1)
     next_run = kwargs.pop('next_run', timezone.now())
 
@@ -75,6 +76,7 @@ def schedule(func, *args, **kwargs):
                                    args=args,
                                    kwargs=kwargs,
                                    schedule_type=schedule_type,
+                                   minutes=minutes,
                                    repeats=repeats,
                                    next_run=next_run
                                    )

django_q/tests/test_scheduler.py

@@ -71,6 +71,13 @@ def test_scheduler(r):
                                       hook='django_q.tests.tasks.result'
                                       )
     assert hasattr(always_schedule, 'pk') is True
+    # Minute schedule
+    minute_schedule = create_schedule('django_q.tests.tasks.word_multiply',
+                                      2,
+                                      word='django',
+                                      schedule_type=Schedule.MINUTES,
+                                      minutes=10)
+    assert hasattr(minute_schedule, 'pk') is True
     # All other types
     for t in Schedule.TYPE:
         schedule = create_schedule('django_q.tests.tasks.word_multiply',