From b454bc2c7085c87504870dd2ce560d8f4701417d Mon Sep 17 00:00:00 2001 From: Monet Lee Date: Thu, 26 Jun 2025 17:19:04 +0800 Subject: [PATCH] fix: update log level in crontask dist look. --- internal/tools/cron/dist_look.go | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/internal/tools/cron/dist_look.go b/internal/tools/cron/dist_look.go index d1d2d1cb0..e46b9206c 100644 --- a/internal/tools/cron/dist_look.go +++ b/internal/tools/cron/dist_look.go @@ -52,15 +52,12 @@ func (e *EtcdLocker) ExecuteWithLock(ctx context.Context, taskName string, task err = mutex.TryLock(ctxWithTimeout) if err != nil { - if err == context.DeadlineExceeded { - log.ZDebug(ctx, "Task is being executed by another instance, skipping", - "taskName", taskName, - "instanceID", e.instanceID) - } else { - log.ZWarn(ctx, "Failed to acquire task lock", err, - "taskName", taskName, - "instanceID", e.instanceID) - } + // errors.Is(err, concurrency.ErrLocked) + log.ZDebug(ctx, "Task is being executed by another instance, skipping", + "taskName", taskName, + "instanceID", e.instanceID, + "error", err.Error()) + return }