|
@@ -105,7 +105,7 @@ def handle_table(table_name: str, spark_task_list: List[Dict]) -> (bool, str, st
|
|
|
if finished_hour != current_hour:
|
|
if finished_hour != current_hour:
|
|
|
return True, f"当前小时的任务未完成", "warn"
|
|
return True, f"当前小时的任务未完成", "warn"
|
|
|
|
|
|
|
|
- return False, ""
|
|
|
|
|
|
|
+ return False, "", ""
|
|
|
|
|
|
|
|
|
|
|
|
|
def invoke_feishu_card_mgs(webhook: str, content: str, alarm_level="error"):
|
|
def invoke_feishu_card_mgs(webhook: str, content: str, alarm_level="error"):
|
