Scheduler

This project is still in alpha stage. Try at your own risk.

Task Scheduler for Django

Scheduler is a simple Django app for scheduling tasks at a specific time or repeating in a pattern based on the rules defined in Recurrence Rule (RRULE) syntax as per the RFC2445 standard.

Special Thanks

• Django - ORM and app system.
• Celery - Task management.
• Dateutil - Interpreting RRULE syntax.

Requirements

• Django 1.8+
• Celery 4.0+

Installation

• Install django-scheduler using git+https method.

  pip install git+https://github.com/tejasjadhav/django-scheduler.git

• Add scheduler in your INSTALLED_APPS

  INSTALLED_APPS = [
  ...,
  'scheduler',
  ...,
  ]

• Do the initial migration

  python manage.py migrate scheduler

Usage

• Add the celery.task or shared_task decorator and specify scheduler.tasks.RepeatTask as the base.

  
  from celery import shared_task
  from scheduler.tasks import RepeatTask

@shared_task(base=RepeatTask) def say_hello(fruit): print(f'Hello, I ate {fruit} today.')

* Make sure atleast one Celery worker is running. Restart your workers so that the changes are reflected in the workers.
* Use `TaskScheduler` to schedule the task. You can specify the starting time, the ending time and the recurrence rule for the task. Arguments and keyword arguments should be specified separately. Task description is mandatory. The task scheduler returns a `task_id` which can be used to cancel the task.
```python
from datetime import timedelta

from django.utils import timezone
from scheduler.scheduler import TaskScheduler

now = timezone.now() + timedelta(hours=3)
tomorrow = now + timedelta(hours=7)

task_id = TaskScheduler.schedule(say_hello,
    description='Speaks out which fruit you ate today',
    args=('Apple', )
    kwargs=None,
    rrule_string='RRULE:FREQ=HOURLY;INTERVAL=2', # Run every 2 hours...
    trigger_at=now, # ...starting 3 hours from now...
    until=tomorrow  # ...till 10 hours from now..
)
print(f'Task ID: {task_id}')  # Task ID: UUID('53f81020-1b77-45cd-8f0d-2c5a8acee6a8')

• Suppose, you run the above snippet at 2017-03-25 01:30:00, the task will execute at the following times,

  [2017-03-25 04:30:00] Hello, I ate Apple today.
  [2017-03-25 06:30:00] Hello, I ate Apple today.
  [2017-03-25 08:30:00] Hello, I ate Apple today.
  [2017-03-25 10:30:00] Hello, I ate Apple today.

• To run this task immediately, set trigger_at as None.
• To run this task infinitely, set until as None.
• To cancel a schedule, use TaskScheduler.cancel method and pass the task_id that was generated by the TaskScheduler.

  TaskScheduler.cancel(task_id)

API

Schedule a task

TaskScheduler.schedule(func, description, args=None, kwargs=None, rrule_string=None, trigger_at=None, until=None)

NOTE: It is important that all the datetime instances passed should have timezone information, i. e., they should be timezone aware. Use Django's timezone.now() utility to get a timezone aware instance with USE_TZ=True in settings.

Returns

Cancel scheduled task

TaskSchedule.cancel(task_id)

Returns

Limitations

• Currently, there is no support for DTSTART and UNTIL rules. Use trigger_at and until parameters. Even if you specify DTSTART and UNTIL rules, they will get overidden.

Testing

To run the tests, make sure you install all the dependencies in requirements.txt and then run runtests.py.

pip install -r requirements.txt
python runtests.py