Function createIntegrationClaimedRun

internal/task/manager_integration_test.go:2368–2409

(
	t *testing.T,
	ctx context.Context,
	db *globaldb.GlobalDB,
	manager *taskpkg.Service,
	creator taskpkg.ActorContext,
	claimer taskpkg.ActorContext,
	workspaceName string,
	title string,
	claimerSessionID string,
	now time.Time,
)

}

func createIntegrationClaimedRun(
	t *testing.T,
	ctx context.Context,
	db *globaldb.GlobalDB,
	manager *taskpkg.Service,
	creator taskpkg.ActorContext,
	claimer taskpkg.ActorContext,
	workspaceName string,
	title string,
	claimerSessionID string,
	now time.Time,
) (*taskpkg.Task, *taskpkg.Run, *taskpkg.ClaimResult) {
	t.Helper()

	workspaceID := registerTaskManagerWorkspace(t, db, workspaceName, filepath.Join(t.TempDir(), workspaceName))
	taskRecord, err := manager.CreateTask(ctx, taskpkg.CreateTask{
		Scope:       taskpkg.ScopeWorkspace,
		WorkspaceID: workspaceID,
		Title:       title,
	}, creator)
	if err != nil {
		t.Fatalf("CreateTask(%q) error = %v", title, err)
	}
	run, err := manager.EnqueueRun(ctx, taskpkg.EnqueueRun{TaskID: taskRecord.ID}, creator)
	if err != nil {
		t.Fatalf("EnqueueRun(%q) error = %v", title, err)
	}
	claim, err := manager.ClaimNextRun(ctx, taskpkg.ClaimCriteria{
		Scope:            taskpkg.ScopeWorkspace,
		WorkspaceID:      workspaceID,
		ClaimerSessionID: claimerSessionID,
		LeaseDuration:    10 * time.Minute,
		Now:              now,
	}, claimer)
	if err != nil {
		t.Fatalf("ClaimNextRun(%q) error = %v", title, err)
	}
	if got, want := claim.Run.ID, run.ID; got != want {
		t.Fatalf("ClaimNextRun(%q).Run.ID = %q, want %q", title, got, want)
	}
	return taskRecord, run, claim
}

func findIntegrationTaskEvent(
	t *testing.T,