fixed tests error

Signed-off-by: Hao Luo <howlowck@gmail.com>
2022-10-26 14:02:32 -05:00
parent 7150d819b3
commit 09d0e5fc61
1 changed files with 2 additions and 1 deletions
@@ -161,6 +161,8 @@ describe('Concurrent TaskWorker', () => {
  const logger = getVoidLogger();

  it('should be able to run multiple tasks at once', async () => {
+    const broker = new StorageTaskBroker(storage, logger);
+
    const dispatchANewTask = () =>
      broker.dispatch({
        spec: {
@@ -174,7 +176,6 @@ describe('Concurrent TaskWorker', () => {
      });

    const expectedConcurrentTasks = 3;
-    const broker = new StorageTaskBroker(storage, logger);
    const taskWorker = await TaskWorker.create({
      logger,
      workingDirectory,