catch thread

冯轩
Showing 1 changed file with 10 additions and 4 deletions
src/celery_compare/tasks.py
--- a/src/celery_compare/tasks.py
View file @48a1a35
+++ b/src/celery_compare/tasks.py
View file @48a1a35
@@ -3715,8 +3715,11 @@ def se_compare(application_id, application_entity, ocr_res_id, last_obj, ocr_res
 @app.task
 def fsm_compare(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True, is_cms=False):
-    producer_thread_fsm = threading.Thread(target=fsm_compare_thread, args=(application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms))
+    try:
-    producer_thread_fsm.start()
+        producer_thread_fsm = threading.Thread(target=fsm_compare_thread, args=(application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms))
+        producer_thread_fsm.start()
+    except Exception as e:
+        compare_log.info('[fsm thread error] [error={0}]'.format(traceback.format_exc()))
 def fsm_compare_thread(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True, is_cms=False):
@@ -3781,8 +3784,11 @@ def fsm_compare_thread(application_id, application_entity, uniq_seq, ocr_res_id,
 @app.task
 def compare(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True, is_cms=False):
-    producer_thread = threading.Thread(target=compare_thread, args=(application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms))
+    try:
-    producer_thread.start()
+        producer_thread = threading.Thread(target=compare_thread, args=(application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms))
+        producer_thread.start()
+    except Exception as e:
+        compare_log.info('[thread error] [error={0}]'.format(traceback.format_exc()))
 def compare_thread(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True, is_cms=False):
    # POS: application_id, application_entity, uniq_seq, None