(status taskpkg.RunStatus)
| 3016 | } |
| 3017 | |
| 3018 | func agentTaskLeaseRecord(status taskpkg.RunStatus) AgentTaskLeaseRecord { |
| 3019 | leaseUntil := fixedTestNow.Add(5 * time.Minute) |
| 3020 | heartbeatAt := fixedTestNow.Add(time.Minute) |
| 3021 | return AgentTaskLeaseRecord{ |
| 3022 | TaskID: "task-1", |
| 3023 | RunID: "run-1", |
| 3024 | Status: status, |
| 3025 | SessionID: "sess-agent", |
| 3026 | ClaimedBy: &taskpkg.ActorIdentity{Kind: taskpkg.ActorKindAgentSession, Ref: "sess-agent"}, |
| 3027 | ClaimTokenHash: "sha256:aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa", |
| 3028 | LeaseUntil: &leaseUntil, |
| 3029 | HeartbeatAt: &heartbeatAt, |
| 3030 | CoordinationChannelID: "builders", |
| 3031 | } |
| 3032 | } |
| 3033 | |
| 3034 | func taskRunRecord(id string, status taskpkg.RunStatus) TaskRunRecord { |
| 3035 | return TaskRunRecord{ |
no test coverage detected