chore(controller): refine celery task priority

Author: duanhongyi

rootfs/api/models/__init__.py

@@ -267,15 +267,21 @@ def config_changed_handle(sender, instance=None, created=False, update_fields=No
             update_fields is not None and (
                 "cpu" in update_fields or "memory" in update_fields))):
         timestamp = time.time()
-        measure_config.delay(instance.to_measurements(timestamp))
+        measure_config.apply_async(
+            args=[instance.to_measurements(timestamp), ],
+            queue="priority.middle",
+        )
 
 
 @receiver(post_save, sender=Volume)
 def volume_changed_handle(sender, instance=None, created=False, update_fields=None, **kwargs):
     # measure volumes to workflow manager
     if settings.WORKFLOW_MANAGER_URL is not None and created:
         timestamp = time.time()
-        measure_volumes.delay(instance.to_measurements(timestamp))
+        measure_volumes.apply_async(
+            args=[instance.to_measurements(timestamp), ],
+            queue="priority.middle",
+        )
 
 
 @receiver(post_save, sender=Resource)
@@ -294,4 +300,7 @@ def resource_changed_handle(sender, instance=None, created=False, update_fields=
                 "plan" in update_fields
             ))):
         timestamp = time.time()
-        measure_resources.delay(instance.to_measurements(timestamp))
+        measure_resources.apply_async(
+            args=[instance.to_measurements(timestamp), ],
+            queue="priority.middle",
+        )

rootfs/api/settings/celery.py

@@ -19,7 +19,7 @@ class Config:
     result_expires = 24 * 60 * 60
     broker_url = os.environ.get('DRYCC_RABBITMQ_URL', 'amqp://guest:guest@127.0.0.1:5672/')  # noqa
     cache_backend = 'django-cache'
-    task_default_queue = 'priority.middle'
+    task_default_queue = 'priority.low'
 
 
 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'api.settings.production')

rootfs/api/tasks.py

@@ -2,10 +2,8 @@
 import time
 import uuid
 import logging
-from datetime import timedelta
 from typing import List, Dict
 from django.core import signals
-from django.utils.timezone import now
 from celery import shared_task
 
 from api import manager