查看任务执行概览¶
使用 AI Studio SDK 读取一个工作区近期任务的执行状态汇总。概览提供运行中、成功、失败、待处理和总数,以及统计窗口天数;它不能替代某个具体任务或工作流运行的状态查询。
任务流程¶
提供已确认的工作区 ID,读取该工作区的近期执行汇总。发现失败或需要追踪的数量后,进入相应资源任务页,用具体任务或运行 ID 读取详情。
准备¶
需要的内容 |
如何取得 |
在本页中的作用 |
|---|---|---|
已认证的客户端 |
在首次接入流程中创建。 |
读取工作区范围的执行汇总。 |
工作区 ID |
从工作区创建、列表或操作者选择中取得。 |
确定统计范围。 |
读取执行概览¶
下面的示例读取工作区近期任务的状态数量和统计窗口。概览只用于定位需要进一步检查的工作;不要把其中的状态数量当作某次运行的最终结果。
import os
import moi_product_sdk as sdk
client = sdk.new_with_personal_access_token(
os.environ["PRODUCT_API_BASE_URL"],
os.environ["PRODUCT_API_KEY"],
)
overview = client.dashboard("<workspace-id>").task_execution_overview()
print(overview.running)
print(overview.success)
print(overview.failed)
print(overview.pending)
print(overview.total)
print(overview.window_days)
package main
import (
"context"
"fmt"
"os"
sdk "github.com/matrixorigin/matrixflow/sdk/go-sdk"
)
func main() {
ctx := context.Background()
client, err := sdk.NewWithPersonalAccessToken(
os.Getenv("PRODUCT_API_BASE_URL"),
os.Getenv("PRODUCT_API_KEY"),
)
if err != nil {
panic(err)
}
overview, err := client.Dashboard("<workspace-id>").TaskExecutionOverview(ctx)
if err != nil {
panic(err)
}
fmt.Println(overview.Running)
fmt.Println(overview.Success)
fmt.Println(overview.Failed)
fmt.Println(overview.Pending)
fmt.Println(overview.Total)
fmt.Println(overview.WindowDays)
}
下一步¶
对需要处理的工作流运行,使用运行并跟踪工作流读取具体状态和结果。
最后更新于