k2safe/orbit
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: add historical sdk compatibility rehearsal

Browse Source
This commit is contained in:
k2safe
2026-09-20 17:27:41 +08:00
parent 25382c3257
commit f02e6af279
9 changed files with 172 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
sdk/go/examples/tasks/main.go
View File

@@ -79,14 +79,17 @@ func run() error {
if err != nil {
return err
}
origin, err := client.GetTaskSource(ctx, current.ID)
if err != nil {
return err
// 仅历史兼容性 smoke 使用 ORBIT_SKIP_SOURCE；正常示例验证当前来源接口。
if os.Getenv("ORBIT_SKIP_SOURCE") == "" {
origin, err := client.GetTaskSource(ctx, current.ID)
if err != nil {
return err
}
if origin.Kind != "DIRECT" {
return fmt.Errorf("expected direct task source")
}
fmt.Printf("source_kind=%s\n", origin.Kind)
}
if origin.Kind != "DIRECT" {
return fmt.Errorf("expected direct task source")
}
fmt.Printf("source_kind=%s\n", origin.Kind)
fmt.Printf("task=%s duplicate=%t listed=%d final_state=%s revision=%d\n", current.ID, again.Deduplicated, len(page.Items), cancelled.Task.State, cancelled.Task.Revision)
if cancelled.Task.State != orbit.TaskCancelled {
return fmt.Errorf("expected CANCELLED")