diff options
| author | Valery Piashchynski <[email protected]> | 2021-09-12 22:10:49 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2021-09-12 22:10:49 +0300 |
| commit | fe72d84395970281fe330a2b9423f8c0e4c3b9c8 (patch) | |
| tree | e797cc898b0a6ae6bb4ac44406e4d765e7db9a83 /tests | |
| parent | fe8ae870ff2bf81a04868d3e42f319d54453a6b1 (diff) | |
| parent | 417857453bea305eeafd11d4acf300fcb9719cf1 (diff) | |
[#795]: fix(jobs, memory): start `jobs` `in-memory` driver automatically if the user consumes it
[#795]: fix(jobs, memory): start `jobs` `in-memory` driver automatically if the user consumes it
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/plugins/jobs/jobs_memory_test.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/tests/plugins/jobs/jobs_memory_test.go b/tests/plugins/jobs/jobs_memory_test.go index 20cbfb3f..7e39c556 100644 --- a/tests/plugins/jobs/jobs_memory_test.go +++ b/tests/plugins/jobs/jobs_memory_test.go @@ -107,7 +107,7 @@ func TestMemoryInit(t *testing.T) { } }() - time.Sleep(time.Second * 3) + time.Sleep(time.Second * 1) stopCh <- struct{}{} wg.Wait() } @@ -229,7 +229,7 @@ func TestMemoryPauseResume(t *testing.T) { mockLogger.EXPECT().Error(gomock.Any(), gomock.Any(), gomock.Any()).AnyTimes() mockLogger.EXPECT().Info("pipeline active", "pipeline", "test-local-2", "start", gomock.Any(), "elapsed", gomock.Any()).Times(1) - mockLogger.EXPECT().Info("pipeline active", "pipeline", "test-local", "start", gomock.Any(), "elapsed", gomock.Any()).Times(3) + mockLogger.EXPECT().Info("pipeline active", "pipeline", "test-local", "start", gomock.Any(), "elapsed", gomock.Any()).Times(2) mockLogger.EXPECT().Info("pipeline paused", "pipeline", "test-local", "driver", "memory", "start", gomock.Any(), "elapsed", gomock.Any()).Times(1) @@ -301,7 +301,6 @@ func TestMemoryPauseResume(t *testing.T) { time.Sleep(time.Second * 3) - t.Run("Resume", resumePipes("test-local")) t.Run("Pause", pausePipelines("test-local")) t.Run("pushToDisabledPipe", pushToDisabledPipe("test-local")) t.Run("Resume", resumePipes("test-local")) |