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

Method recordTaskBlockExpired

internal/task/block_service.go:167–183  ·  view source on GitHub ↗
(
	ctx context.Context,
	block TaskBlock,
	reconciled Task,
	actor ActorContext,
)

Source from the content-addressed store, hash-verified

165}
166
167func (m *Service) recordTaskBlockExpired(
168 ctx context.Context,
169 block TaskBlock,
170 reconciled Task,
171 actor ActorContext,
172) {
173 if eventErr := m.recordTaskEvent(ctx, block.TaskID, "", taskEventBlockExpired, actor, taskBlockExpiredPayload{
174 Status: reconciled.Status,
175 BlockID: strings.TrimSpace(block.ID),
176 BlockKind: block.Kind.Normalize(),
177 Reason: redactTaskSecretText(strings.TrimSpace(block.Reason)),
178 ExpiresAt: block.ExpiresAt,
179 ClearedAt: block.ClearedAt,
180 }); eventErr != nil {
181 m.logTaskBlockEventFailure(eventErr, taskEventBlockExpired, block, "")
182 }
183}
184
185func (m *Service) logTaskBlockEventFailure(err error, eventType string, block TaskBlock, runID string) {
186 slog.Error(

Callers 1

ExpireTaskBlocksMethod · 0.95

Calls 4

recordTaskEventMethod · 0.95
redactTaskSecretTextFunction · 0.85
NormalizeMethod · 0.45

Tested by

no test coverage detected