Method logTaskBlockEventFailure

internal/task/block_service.go:185–194

(err error, eventType string, block TaskBlock, runID string)

}

func (m *Service) logTaskBlockEventFailure(err error, eventType string, block TaskBlock, runID string) {
	slog.Error(
		"task: task block event failed after committed mutation",
		"error", err,
		"event_type", eventType,
		"task_id", block.TaskID,
		"run_id", strings.TrimSpace(runID),
		"block_id", block.ID,
	)
}

func (m *Service) requireAgentSessionTaskLease(ctx context.Context, taskID string, actor ActorContext) error {
	if actor.Actor.Kind.Normalize() != ActorKindAgentSession {