MOD:celery

冯轩
Showing 2 changed files with 3 additions and 3 deletions
src/celery_compare/__init__.py
src/celery_compare/tasks.py
--- a/src/celery_compare/__init__.py
View file @f26fe22
+++ b/src/celery_compare/__init__.py
View file @f26fe22
@@ -8,4 +8,4 @@ broker = conf.CELERY_BROKER_URL
 app = Celery('celery_compare', broker=broker, include=['celery_compare.tasks'])
-app.conf.update(worker_max_tasks_per_child=5, timezone='Asia/Shanghai')
+app.conf.update(worker_max_tasks_per_child=10, timezone='Asia/Shanghai')
--- a/src/celery_compare/tasks.py
View file @f26fe22
+++ b/src/celery_compare/tasks.py
View file @f26fe22
@@ -3730,7 +3730,7 @@ def fsm_compare(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=
    #     results = list(executor.map(fsm_compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms))
    compare_log.info('[fsm thread]')
-    pool = ThreadPoolExecutor(max_workers=5, thread_name_prefix="fsm_thread_")
+    pool = ThreadPoolExecutor(max_workers=6, thread_name_prefix="fsm_thread_")
    pool.submit(fsm_compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms)
    pool.shutdown(wait=True)
@@ -3808,7 +3808,7 @@ def compare(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True
    #     results = list(executor.map(compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms))
    compare_log.info('[non fsm thread]')
-    pool = ThreadPoolExecutor(max_workers=5, thread_name_prefix="non_fsm_thread_")
+    pool = ThreadPoolExecutor(max_workers=6, thread_name_prefix="non_fsm_thread_")
    pool.submit(compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms)
    pool.shutdown(wait=True)