diff --git a/services/frontend-service/pkg/service/batch.go b/services/frontend-service/pkg/service/batch.go index d57670c54..149f02785 100644 --- a/services/frontend-service/pkg/service/batch.go +++ b/services/frontend-service/pkg/service/batch.go @@ -46,7 +46,7 @@ func (b *BatchServiceWithDefaultTimeout) ProcessBatch(ctx context.Context, req * if ctx.Err() != nil { if context.Cause(ctx) == kuberpultTimeoutError { - logger.FromContext(ctx).Warn(fmt.Sprintf("Context cancelled due to %s", kuberpultTimeoutError.Error())) + logger.FromContext(ctx).Warn(fmt.Sprintf("ProcessBatch context cancelled due to %s", kuberpultTimeoutError.Error())) } else { logger.FromContext(ctx).Warn("ProcessBatch context cancelled NOT due to kuberpult timeout.", zap.Error(context.Cause(ctx))) }