Lines Matching refs:td
22 "go.skia.org/infra/task_driver/go/td"
49 ctx := td.StartRun(projectId, taskId, taskName, output, local)
50 defer td.EndRun(ctx)
52 td.Fatalf(ctx, "--roller_name must be specified")
57 td.Fatal(ctx, skerr.Wrap(err))
60 td.Fatalf(ctx, "This task driver should be run only as a try bot")
66 td.Fatal(ctx, skerr.Wrap(err))
70 td.StepText(ctx, "Canary roll doc", "https://goto.google.com/autoroller-canary-bots")
75 td.Fatal(ctx, skerr.Wrap(err))
99 if err := td.Do(ctx, td.Props(fmt.Sprintf("Trigger canary roll%s", retryText)).Infra(), func(ctx context.Context) error {
103 td.Fatal(ctx, skerr.Wrap(err))
110 td.Fatal(ctx, skerr.Wrapf(err, "failed inspite of 3 retries"))
116 td.Fatal(ctx, skerr.Wrap(err))
126 ctx := td.StartStep(parentCtx, td.Props(stepName))
127 defer td.EndStep(ctx)
131 stdout := td.NewLogStream(ctx, "stdout", td.SeverityInfo)
135 return td.FailStep(ctx, fmt.Errorf("Could not find canary roll with ID: %s", rollId))
144 td.StepText(ctx, "Canary roll CL", cl)
145 td.StepText(parentCtx, "Canary roll CL", cl)
151 return td.FailStep(ctx, fmt.Errorf("Could not write to stdout: %s", err))
161 return td.FailStep(ctx, canaryRollSuccessTooQuicklyErr)
166 return td.FailStep(ctx, canaryRollNotCreatedErr)
168 return td.FailStep(ctx, fmt.Errorf("Canary roll [ %s ] failed", cl))
170 return td.FailStep(ctx, fmt.Errorf("Canary roll [ %s ] completed with an unknown result", cl))