MCPcopy Create free account
hub / github.com/compozy/agh / ClaimNextRun

Method ClaimNextRun

internal/task/interfaces.go:61–61  ·  view source on GitHub ↗
(ctx context.Context, criteria ClaimCriteria, actor ActorContext)

Source from the content-addressed store, hash-verified

59
60 EnqueueRun(ctx context.Context, spec EnqueueRun, actor ActorContext) (*Run, error)
61 ClaimNextRun(ctx context.Context, criteria ClaimCriteria, actor ActorContext) (*ClaimResult, error)
62 ClaimRun(ctx context.Context, runID string, claim ClaimRun, actor ActorContext) (*Run, error)
63 StartRun(ctx context.Context, runID string, req StartRun, actor ActorContext) (*Run, error)
64 AttachRunSession(ctx context.Context, runID string, sessionID string, actor ActorContext) (*Run, error)

Callers 15

TestSchedulerWakeLeavesClaimToTaskServiceIntegrationFunction · 0.65
TestSchedulerRecoversExpiredLeaseAfterDatabaseRestartIntegrationFunction · 0.65
TestSchedulerRecoversExpiredHistoricalNetworkLeaseIntegrationFunction · 0.65
TestSchedulerRequeuesDeadWorkerLeaseAndWakesReplacementIntegrationFunction · 0.65
TestSchedulerNoEligibleSessionDoesNotClaimIntegrationFunction · 0.65
TestTokenFencedLeaseTransitionsDispatchTaskRunHooksFunction · 0.65
TestTaskLevelHooksDispatchAtServiceCallSitesFunction · 0.65
TestManagerTaskBlockAgentSessionScopeFunction · 0.65
claimNextRunForPostCommitHookTestFunction · 0.65
TestManagerClaimNextRunAndLeaseFencingFunction · 0.65
setupCompletionLeaseForTestFunction · 0.65
TestManagerBlockTaskAndReleaseRunParksActiveLeaseFunction · 0.65

Implementers 2

Serviceinternal/task/manager.go
StubTaskManagerinternal/api/testutil/task_stub.go

Calls

no outgoing calls

Tested by 15

TestSchedulerWakeLeavesClaimToTaskServiceIntegrationFunction · 0.52
TestSchedulerRecoversExpiredLeaseAfterDatabaseRestartIntegrationFunction · 0.52
TestSchedulerRecoversExpiredHistoricalNetworkLeaseIntegrationFunction · 0.52
TestSchedulerRequeuesDeadWorkerLeaseAndWakesReplacementIntegrationFunction · 0.52
TestSchedulerNoEligibleSessionDoesNotClaimIntegrationFunction · 0.52
TestTokenFencedLeaseTransitionsDispatchTaskRunHooksFunction · 0.52
TestTaskLevelHooksDispatchAtServiceCallSitesFunction · 0.52
TestManagerTaskBlockAgentSessionScopeFunction · 0.52
claimNextRunForPostCommitHookTestFunction · 0.52
TestManagerClaimNextRunAndLeaseFencingFunction · 0.52
setupCompletionLeaseForTestFunction · 0.52
TestManagerBlockTaskAndReleaseRunParksActiveLeaseFunction · 0.52