Skip to content

Commit f5ca14b

Browse files
committed
fix
1 parent 32b5484 commit f5ca14b

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

dbos/system_database.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2691,7 +2691,9 @@ func retry(ctx context.Context, fn func() error, options ...retryOption) error {
26912691

26922692
// Check if error is retryable
26932693
if !config.retryCondition(lastErr) {
2694-
config.logger.Debug("Non-retryable error encountered", "error", lastErr)
2694+
if config.logger != nil {
2695+
config.logger.Debug("Non-retryable error encountered", "error", lastErr)
2696+
}
26952697
return lastErr
26962698
}
26972699

@@ -2719,7 +2721,9 @@ func retry(ctx context.Context, fn func() error, options ...retryOption) error {
27192721
select {
27202722
case <-time.After(jitteredDelay):
27212723
case <-ctx.Done():
2722-
config.logger.Error("Operation cancelled", "error", ctx.Err())
2724+
if config.logger != nil {
2725+
config.logger.Debug("Retry operation cancelled", "error", ctx.Err())
2726+
}
27232727
return ctx.Err()
27242728
}
27252729

0 commit comments

Comments
 (0)