From 5f8bbf8590c130553e341c53ab0988444a841721 Mon Sep 17 00:00:00 2001
From: bidaya0 <xianzelin@huoxian.cn>
Date: Fri, 16 Dec 2022 12:53:01 +0800
Subject: [PATCH] fix: celery fix pep8 lint.

---
 dongtai_conf/celery.py | 29 +++++++++++++++++++++--------
 1 file changed, 21 insertions(+), 8 deletions(-)

diff --git a/dongtai_conf/celery.py b/dongtai_conf/celery.py
index 0ebb5a0ce..1457d98f5 100644
--- a/dongtai_conf/celery.py
+++ b/dongtai_conf/celery.py
@@ -26,13 +26,25 @@
 
 configs["task_queues"] = [
     # normal
-    Queue("dongtai-method-pool-scan", Exchange("dongtai-method-pool-scan"), routing_key="dongtai-method-pool-scan"),
-    Queue("dongtai-replay-vul-scan", Exchange("dongtai-replay-vul-scan"), routing_key="dongtai-replay-vul-scan"),
-    Queue("dongtai-sca-task", Exchange("dongtai-sca-task"), routing_key="dongtai-sca-task"),
-    Queue("dongtai-function-flush-data", Exchange("dongtai-function-flush-data"), routing_key="dongtai-function-flush-data"),
-    Queue("dongtai-es-save-task", Exchange("dongtai-es-save-task"), routing_key="dongtai-es-save-task"),
+    Queue("dongtai-method-pool-scan",
+          Exchange("dongtai-method-pool-scan"),
+          routing_key="dongtai-method-pool-scan"),
+    Queue("dongtai-replay-vul-scan",
+          Exchange("dongtai-replay-vul-scan"),
+          routing_key="dongtai-replay-vul-scan"),
+    Queue("dongtai-sca-task",
+          Exchange("dongtai-sca-task"),
+          routing_key="dongtai-sca-task"),
+    Queue("dongtai-function-flush-data",
+          Exchange("dongtai-function-flush-data"),
+          routing_key="dongtai-function-flush-data"),
+    Queue("dongtai-es-save-task",
+          Exchange("dongtai-es-save-task"),
+          routing_key="dongtai-es-save-task"),
     # cronjob
-    Queue("dongtai-periodic-task", Exchange("dongtai-periodic-task"), routing_key="dongtai-periodic-task"),
+    Queue("dongtai-periodic-task",
+          Exchange("dongtai-periodic-task"),
+          routing_key="dongtai-periodic-task"),
 ]
 # celery config
 configs['task_serializer'] = 'json'
@@ -42,8 +54,9 @@
 configs['task_acks_late'] = True
 configs['task_acks_on_failure_or_timeout'] = True
 configs['broker_connection_retry_on_startup'] = False
-configs['broker_connection_max_retries'] = 0 # it means retry forever
-configs['broker_pool_limit'] = 1000 # to forbid contention can arise when using gevent.
+configs['broker_connection_max_retries'] = 0  # it means retry forever
+configs[
+    'broker_pool_limit'] = 1000  # to forbid contention can arise when using gevent.
 # configs['worker_concurrency'] = 8
 configs["task_routes"] = {
     # normal