Sep 23, 2025 · Sep 23, 2025
diff --git a/scaletest/createworkspaces/run_test.go b/scaletest/createworkspaces/run_test.go
 // Wait for the workspace build job to be picked up.
 checkJobStartedCtx := testutil.Context(t, testutil.WaitLong)
 jobCh := make(chan codersdk.ProvisionerJob, 1)
 require.Eventually(t, func() bool {
 testutil.Eventually(checkJobStartedCtx,t, func(ctx context.Context) bool {
 workspaces, err := client.Workspaces(checkJobStartedCtx, codersdk.WorkspaceFilter{})
 if err != nil {
 return false
 }
 jobCh <- ws.LatestBuild.Job
 return true
 }, testutil.WaitLong, testutil.IntervalSlow)
 }, testutil.IntervalSlow)

 t.Log("canceling scaletest workspace creation")
 runnerCancel()
 }()

 // Ensure the job has been marked as canceled
 checkJobCanceledCtx := testutil.Context(t, testutil.WaitLong)
 require.Eventually(t, func() bool {
 pj, err := client.OrganizationProvisionerJob(checkJobCanceledCtx, runningJob.OrganizationID, runningJob.ID)
 testutil.Eventually(cleanupCtx, t, func(ctx context.Context) bool {
 pj, err := client.OrganizationProvisionerJob(ctx, runningJob.OrganizationID, runningJob.ID)
 if !assert.NoError(t, err) {
 return false
 }
 }

 return true
 }, testutil.WaitLong, testutil.IntervalSlow)
 }, testutil.IntervalSlow)
 cleanupCancel()
 <-done
 cleanupLogsStr := cleanupLogs.String()
Original file line number	Diff line number	Diff line change
Expand Up		@@ -264,7 +264,7 @@ func Test_Runner(t *testing.T) {
		// Wait for the workspace build job to be picked up.
		checkJobStartedCtx := testutil.Context(t, testutil.WaitLong)
		jobCh := make(chan codersdk.ProvisionerJob, 1)
		require.Eventually(t, func() bool {
		testutil.Eventually(checkJobStartedCtx,t, func(ctx context.Context) bool {
		workspaces, err := client.Workspaces(checkJobStartedCtx, codersdk.WorkspaceFilter{})
		if err != nil {
		return false
Expand All		@@ -286,7 +286,7 @@ func Test_Runner(t *testing.T) {
		}
		jobCh <- ws.LatestBuild.Job
		return true
		}, testutil.WaitLong, testutil.IntervalSlow)
		}, testutil.IntervalSlow)

		t.Log("canceling scaletest workspace creation")
		runnerCancel()
Expand All		@@ -308,9 +308,8 @@ func Test_Runner(t *testing.T) {
		}()

		// Ensure the job has been marked as canceled
		checkJobCanceledCtx := testutil.Context(t, testutil.WaitLong)
		require.Eventually(t, func() bool {
		pj, err := client.OrganizationProvisionerJob(checkJobCanceledCtx, runningJob.OrganizationID, runningJob.ID)
		testutil.Eventually(cleanupCtx, t, func(ctx context.Context) bool {
		pj, err := client.OrganizationProvisionerJob(ctx, runningJob.OrganizationID, runningJob.ID)
		if !assert.NoError(t, err) {
		return false
		}
Expand All		@@ -324,7 +323,7 @@ func Test_Runner(t *testing.T) {
		}

		return true
		}, testutil.WaitLong, testutil.IntervalSlow)
		}, testutil.IntervalSlow)
		cleanupCancel()
		<-done
		cleanupLogsStr := cleanupLogs.String()
Expand Down