diff --git a/pkg/innerring/processors/alphabet/handlers_test.go b/pkg/innerring/processors/alphabet/handlers_test.go index 5e71cbc908..c098ca27d5 100644 --- a/pkg/innerring/processors/alphabet/handlers_test.go +++ b/pkg/innerring/processors/alphabet/handlers_test.go @@ -2,7 +2,6 @@ package alphabet_test import ( "testing" - "time" "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/innerring" "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/innerring/processors/alphabet" @@ -140,7 +139,7 @@ func TestProcessorEmitsGasToNetmapIfNoParsedWallets(t *testing.T) { processor.HandleGasEmission(timers.NewAlphabetEmitTick{}) - time.Sleep(time.Second) + processor.WaitPoolRunning() require.EqualValues(t, []invokedMethod{ { @@ -201,7 +200,7 @@ func TestProcessorDoesntEmitGasIfNoNetmapOrParsedWallets(t *testing.T) { processor.HandleGasEmission(timers.NewAlphabetEmitTick{}) - time.Sleep(time.Second) + processor.WaitPoolRunning() require.EqualValues(t, []invokedMethod{ { diff --git a/pkg/innerring/processors/frostfs/handlers_test.go b/pkg/innerring/processors/frostfs/handlers_test.go index ee2a00427b..db78358115 100644 --- a/pkg/innerring/processors/frostfs/handlers_test.go +++ b/pkg/innerring/processors/frostfs/handlers_test.go @@ -254,7 +254,9 @@ func TestHandleUnbind(t *testing.T) { proc.handleBind(evBind) - time.Sleep(time.Second) + for proc.pool.Running() > 0 { + time.Sleep(10 * time.Millisecond) + } require.EqualValues(t, []frostfsid.CommonBindPrm{expBind}, id.remove, "invalid remove keys value") require.EqualValues(t, []frostfsid.CommonBindPrm{expBind}, id.add, "invalid add keys value")