( ctx context.Context, block TaskBlock, reconciled Task, actor ActorContext, release *BlockTaskAndReleaseRunResult, )
| 122 | } |
| 123 | |
| 124 | func (m *Service) recordTaskBlockCreated( |
| 125 | ctx context.Context, |
| 126 | block TaskBlock, |
| 127 | reconciled Task, |
| 128 | actor ActorContext, |
| 129 | release *BlockTaskAndReleaseRunResult, |
| 130 | ) { |
| 131 | runID := "" |
| 132 | claimTokenHash := "" |
| 133 | if release != nil { |
| 134 | runID = strings.TrimSpace(release.Run.ID) |
| 135 | claimTokenHash = strings.TrimSpace(release.ClaimTokenHash) |
| 136 | } |
| 137 | if eventErr := m.recordTaskEvent(ctx, block.TaskID, runID, taskEventBlockCreated, actor, taskBlockCreatedPayload{ |
| 138 | Status: reconciled.Status, |
| 139 | BlockID: strings.TrimSpace(block.ID), |
| 140 | BlockKind: block.Kind.Normalize(), |
| 141 | Reason: redactTaskSecretText(strings.TrimSpace(block.Reason)), |
| 142 | ExpiresAt: block.ExpiresAt, |
| 143 | ClaimTokenHash: claimTokenHash, |
| 144 | }); eventErr != nil { |
| 145 | m.logTaskBlockEventFailure(eventErr, taskEventBlockCreated, block, runID) |
| 146 | } |
| 147 | } |
| 148 | |
| 149 | func (m *Service) recordTaskBlockCleared( |
| 150 | ctx context.Context, |
no test coverage detected