Lines Matching refs:ctx
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")
64 ts, err := auth_steps.Init(ctx, *local, auth.ScopeUserinfoEmail, datastore.ScopeDatastore)
66 td.Fatal(ctx, skerr.Wrap(err))
70 td.StepText(ctx, "Canary roll doc", "https://goto.google.com/autoroller-canary-bots")
73 manualRollDB, err := manual.NewDBWithParams(ctx, firestore.FIRESTORE_PROJECT, "production", ts)
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))
106 if err := waitForCanaryRoll(ctx, manualRollDB, req.Id, fmt.Sprintf("Wait for canary roll%s", retryText)); err != nil {
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)
133 roll, err := manualRollDB.Get(ctx, rollId)
135 return td.FailStep(ctx, fmt.Errorf("Could not find canary roll with ID: %s", rollId))
144 td.StepText(ctx, "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))