MOD：catch sleep

冯轩
Showing 1 changed file with 9 additions and 0 deletions
src/celery_compare/tasks.py
--- a/src/celery_compare/tasks.py
View file @b71dd59
+++ b/src/celery_compare/tasks.py
View file @b71dd59
@@ -3679,7 +3679,10 @@ def se_compare(application_id, application_entity, ocr_res_id, last_obj, ocr_res
                compare_log.info('[get cms_delay_time_config fail] [error={0}]'.format(traceback.format_exc()))
            compare_log.info('cms_delay_time:{0}'.format(cms_delay_time))
+            try:
                time.sleep(int(cms_delay_time))
+            except Exception as e:
+                compare_log.info('[sleep error] [error={0}]'.format(traceback.format_exc()))
            compare_log.info('{0} [SE] [cms sleep end] [entity={1}] [id={2}] '.format(log_base, application_entity, application_id))
            response = cms.send(data)  # interface_report ocr to cms
        except Exception as e:
@@ -3739,7 +3742,10 @@ def fsm_compare_thread(application_id, application_entity, uniq_seq, ocr_res_id,
            compare_log.info('[get delay_time_config fail] [error={0}]'.format(traceback.format_exc()))
        compare_log.info('delay_time:{0}'.format(delay_time))
        compare_log.info('{0} [comparison unfinished file wait delay_time start] [entity={1}] [id={2}] [doc_id={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result.id))
+        try:
            time.sleep(int(delay_time))
+        except Exception as e:
+            compare_log.info('[sleep error] [error={0}]'.format(traceback.format_exc()))
        compare_log.info('{0} [comparison unfinished file wait delay_time end] [entity={1}] [id={2}] [doc_id={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result.id))
@@ -3804,7 +3810,10 @@ def compare_thread(application_id, application_entity, uniq_seq, ocr_res_id, is_
            compare_log.info('[get delay_time_config fail] [error={0}]'.format(traceback.format_exc()))
        compare_log.info('delay_time:{0}'.format(delay_time))
        compare_log.info('{0} [comparison unfinished file wait delay_time start] [entity={1}] [id={2}] [doc_id={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result.id))
+        try:
            time.sleep(int(delay_time))
+        except Exception as e:
+            compare_log.info('[sleep error] [error={0}]'.format(traceback.format_exc()))
        compare_log.info('{0} [comparison unfinished file wait delay_time end] [entity={1}] [id={2}] [doc_id={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result.id))