保持运行连接
提交后,保持到选定 Worker 的WatchTasks 连接。该流先发送当前快照,再发送终态更新。连接中断时,在配置的宽限期内重连。GetTaskResult 可以查看结果,但不会维持运行中任务的连接。
读取终态结果
使用
ReturnValueHandler 时,读取返回输出。写表时,保留 Writer 统计及可能存在的 job_id,再单独确认存储就绪。
决定是否重复执行
- 区分 RPC 或连接失败与已返回的任务失败。
- 提交结果不确定时,查询原任务。
- 先修正输入、函数或配置错误。
- 如果任务已进入 Writer Plugin,检查已有写入状态。
- 确认适合再次执行后,再创建新的工作。