From 69aa3ebafca88ba562ae1c7ecd882a739f339ba0 Mon Sep 17 00:00:00 2001 From: Lev Zakharov Date: Tue, 27 Jun 2023 15:26:48 +0300 Subject: [PATCH 1/2] Fix sleep period in periodic enqueuer --- periodic_enqueuer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/periodic_enqueuer.go b/periodic_enqueuer.go index 9b7a996e..68e19ad5 100644 --- a/periodic_enqueuer.go +++ b/periodic_enqueuer.go @@ -137,7 +137,7 @@ func (pe *periodicEnqueuer) shouldEnqueue() bool { return true } - return lastEnqueue < (nowEpochSeconds() - int64(periodicEnqueuerSleep/time.Minute)) + return lastEnqueue < (nowEpochSeconds() - int64(periodicEnqueuerSleep/time.Second)) } func makeUniquePeriodicID(name, spec string, epoch int64) string { From 4f7ac25914b8f7fbc786fdad0a315966711eb8c0 Mon Sep 17 00:00:00 2001 From: Lev Zakharov Date: Tue, 27 Jun 2023 15:54:46 +0300 Subject: [PATCH 2/2] fix test --- periodic_enqueuer_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/periodic_enqueuer_test.go b/periodic_enqueuer_test.go index e1c9d19b..ff80fe23 100644 --- a/periodic_enqueuer_test.go +++ b/periodic_enqueuer_test.go @@ -94,7 +94,7 @@ func TestPeriodicEnqueuer(t *testing.T) { assert.False(t, pe.shouldEnqueue()) - setNowEpochSecondsMock(1468359454 + int64(periodicEnqueuerSleep/time.Minute) + 10) + setNowEpochSecondsMock(1468359454 + int64(periodicEnqueuerSleep/time.Second) + 10) assert.True(t, pe.shouldEnqueue()) }