Add scheduled jobs (#2743)

* Add scheduled jobs

* regenerating migration, adding __core__ to model

* moving to LockManager pattern

* updating change with new table

* using TimedRetryPolicy instead of manually creating locks

* fixing CHANGES

* updating migration

* adding ted and jtcunning's comments

* flipping info to debug when there's more than 100 jobs

* addressing ted's comments

* fixing ted comments

Author: dcramer

CHANGES

@@ -37,6 +37,9 @@ Schema Changes
 - Added GroupResolution.actor_id
 - Added Project.platform
 - Added GroupSnooze.actor_id
+- Added ScheduledJob
+- Added GroupResolution.actor_id
+- Added ``ScheduledJob`` model
 
 API Changes
 ~~~~~~~~~~~

src/sentry/conf/server.py

@@ -529,6 +529,13 @@ def create_partitioned_queues(name):
             'queue': 'auth',
         }
     },
+    'enqueue-scheduled-jobs': {
+        'task': 'sentry.tasks.enqueue_scheduled_jobs',
+        'schedule': timedelta(minutes=1),
+        'options': {
+            'expires': 60,
+        },
+    },
     'send-beacon': {
         'task': 'sentry.tasks.send_beacon',
         'schedule': timedelta(hours=1),

src/sentry/models/scheduledjob.py

@@ -0,0 +1,22 @@
+from __future__ import absolute_import, print_function
+
+from django.db import models
+from django.utils import timezone
+from jsonfield import JSONField
+
+from sentry.db.models import Model, sane_repr
+
+
+class ScheduledJob(Model):
+    __core__ = False
+
+    name = models.CharField(max_length=128)
+    payload = JSONField()
+    date_added = models.DateTimeField(default=timezone.now)
+    date_scheduled = models.DateTimeField()
+
+    class Meta:
+        app_label = 'sentry'
+        db_table = 'sentry_scheduledjob'
+
+    __repr__ = sane_repr('name', 'date_scheduled')