Ver código fonte

HUE-3797 [scheduler] Preparing submit API for beat

Romain 6 anos atrás
pai
commit
a5604d9841

+ 1 - 1
desktop/core/src/desktop/celery.py

@@ -50,7 +50,7 @@ def debug_task(self):
   return 'Hello'
 
 
-if 'django_celery_beat' in INSTALLED_APPS:
+if 'django_celery_beat' in INSTALLED_APPS and False: # Config not available yet
   app.conf.beat_schedule = {}
 
   if TASK_SERVER.BEAT_SCHEDULES_FILE.get():

+ 4 - 1
desktop/core/src/desktop/lib/scheduler/lib/beat.py

@@ -30,6 +30,9 @@ class CeleryBeatApi(Api):
 
     task, created = PeriodicTask.objects.get_or_create(
       interval=schedule,
-      name='Scheduled query',
+      name='Scheduled query N',
       task='notebook.tasks.run_sync_query',
     )
+
+    task.enabled = True
+    task.save()