|
|
@@ -54,7 +54,7 @@ filter_date = datetime(2024, 1, 1)
|
|
|
def handle_table(table_name: str, spark_task_list: List[Dict]) -> (bool, str):
|
|
|
filtered_data = [
|
|
|
item for item in spark_task_list
|
|
|
- if table_name in item['name'] and date_util.str_cover_date(item['startedTime']) > filter_date
|
|
|
+ if table_name in item['name'] and date_util.str_cover_date(item['finishedTime']) > filter_date
|
|
|
]
|
|
|
if filtered_data:
|
|
|
latest_started_time = max(
|
|
|
@@ -97,7 +97,7 @@ def send_error_info(table_name: str, latest_started_time: str, webhook: str):
|
|
|
"zh_cn": {
|
|
|
"title": {
|
|
|
"tag": "plain_text",
|
|
|
- "content": "【测试】特征同步延迟告警"
|
|
|
+ "content": "特征同步延迟告警"
|
|
|
},
|
|
|
"subtitle": {
|
|
|
"tag": "plain_text",
|
