From c49ff6b31524c18eb09570eb9696d52afa1704d4 Mon Sep 17 00:00:00 2001 From: AlexCXC <1223408988@qq.com> Date: Thu, 10 Aug 2023 10:10:54 +0800 Subject: [PATCH 1/2] opt CDS syncer log WARNING/ERROR --- dtable_events/common_dataset/common_dataset_syncer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dtable_events/common_dataset/common_dataset_syncer.py b/dtable_events/common_dataset/common_dataset_syncer.py index 328845e9..a6905679 100644 --- a/dtable_events/common_dataset/common_dataset_syncer.py +++ b/dtable_events/common_dataset/common_dataset_syncer.py @@ -178,10 +178,11 @@ def check_common_dataset(session_class): continue else: if result.get('error_msg'): - logging.error(result['error_msg']) if result.get('error_type') == 'generate_synced_columns_error': logging.warning('src_dtable_uuid: %s src_table_id: %s src_view_id: %s dst_dtable_uuid: %s dst_table_id: %s generate sync-columns error: %s', src_dtable_uuid, src_table_id, src_view_id, dst_dtable_uuid, dst_table_id, result) + else: + logging.error(result['error_msg']) continue sql = ''' UPDATE dtable_common_dataset_sync SET last_sync_time=:last_sync_time, src_version=:src_version From d60d73a8a1165dfb21176bd19d5da12a54ff2c5b Mon Sep 17 00:00:00 2001 From: AlexCXC <1223408988@qq.com> Date: Thu, 10 Aug 2023 10:14:13 +0800 Subject: [PATCH 2/2] opt log content --- dtable_events/common_dataset/common_dataset_syncer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dtable_events/common_dataset/common_dataset_syncer.py b/dtable_events/common_dataset/common_dataset_syncer.py index a6905679..995c9913 100644 --- a/dtable_events/common_dataset/common_dataset_syncer.py +++ b/dtable_events/common_dataset/common_dataset_syncer.py @@ -182,7 +182,8 @@ def check_common_dataset(session_class): logging.warning('src_dtable_uuid: %s src_table_id: %s src_view_id: %s dst_dtable_uuid: %s dst_table_id: %s generate sync-columns error: %s', src_dtable_uuid, src_table_id, src_view_id, dst_dtable_uuid, dst_table_id, result) else: - logging.error(result['error_msg']) + logging.error('src_dtable_uuid: %s src_table_id: %s src_view_id: %s dst_dtable_uuid: %s dst_table_id: %s error: %s', + src_dtable_uuid, src_table_id, src_view_id, dst_dtable_uuid, dst_table_id, result) continue sql = ''' UPDATE dtable_common_dataset_sync SET last_sync_time=:last_sync_time, src_version=:src_version