From 6aa2a0dc8a73b9e6f070b6e1dae8d51e8e2dc995 Mon Sep 17 00:00:00 2001 From: cyhone Date: Tue, 17 Aug 2021 21:34:03 +0800 Subject: [PATCH] refactor: simplify serverlock code (#37451) --- pkg/infra/serverlock/serverlock.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/infra/serverlock/serverlock.go b/pkg/infra/serverlock/serverlock.go index e662f85af4f..95b2027a81f 100644 --- a/pkg/infra/serverlock/serverlock.go +++ b/pkg/infra/serverlock/serverlock.go @@ -39,7 +39,7 @@ func (sl *ServerLockService) LockAndExecute(ctx context.Context, actionName stri // avoid execution if last lock happened less than `maxInterval` ago if rowLock.LastExecution != 0 { lastExecutionTime := time.Unix(rowLock.LastExecution, 0) - if lastExecutionTime.Unix() > time.Now().Add(-maxInterval).Unix() { + if time.Since(lastExecutionTime) < maxInterval { return nil } }