chore(deploy): add apply tasks

Author: duanhongyi

rootfs/api/settings/production.py

@@ -300,6 +300,9 @@
 
 IMAGE_PULL_POLICY = os.environ.get('IMAGE_PULL_POLICY', "IfNotPresent")
 
+# apply task size
+DRYCC_APPLY_TASKS = int(os.environ.get('DRYCC_APPLY_TASKS', '20'))
+
 # Drycc filer image
 # Provide get and put operations for `drycc volumes:client`
 DRYCC_FILER_IMAGE = os.environ.get('DRYCC_FILER_IMAGE', 'registry.drycc.cc/drycc/filer:canary')

rootfs/api/utils.py

@@ -18,6 +18,7 @@
 import jsonschema
 from copy import deepcopy
 from django.db import models
+from django.conf import settings
 from django.core.cache import cache
 from asgiref.sync import sync_to_async
 from requests_toolbelt import user_agent
@@ -159,7 +160,7 @@ def apply_tasks(tasks):
     if not tasks:
         return
 
-    executor = concurrent.futures.ThreadPoolExecutor(5)
+    executor = concurrent.futures.ThreadPoolExecutor(settings.DRYCC_APPLY_TASKS)
     for future, callback in [(executor.submit(task[0]), task[1]) for task in tasks]:
         future.add_done_callback(callback)
         error = future.exception()