@@ -105,7 +105,8 @@ def handle_table(table_name: str, spark_task_list: List[Dict]) -> (bool, str):
return False, filtered_data
- return False, ""
+ # 如果没有找到，表示近七个小时都没有同步过
+ return True, "七小时之前"
def send_error_info(table_name: str, latest_started_time: str, webhook: str):
