diff --git a/ui/src/app/views/workflow/run/node/pipeline/workflow-run-job/workflow-run-job.component.ts b/ui/src/app/views/workflow/run/node/pipeline/workflow-run-job/workflow-run-job.component.ts
index e690d621d5..ed2ce52719 100644
--- a/ui/src/app/views/workflow/run/node/pipeline/workflow-run-job/workflow-run-job.component.ts
+++ b/ui/src/app/views/workflow/run/node/pipeline/workflow-run-job/workflow-run-job.component.ts
@@ -11,7 +11,7 @@ import { ProjectState } from 'app/store/project.state';
 import { WorkflowState } from 'app/store/workflow.state';
 import * as moment from 'moment';
 import { from, interval, Subject, Subscription } from 'rxjs';
-import { delay, mergeMap, retryWhen } from 'rxjs/operators';
+import { delay, concatMap, retryWhen } from 'rxjs/operators';
 import { webSocket, WebSocketSubject } from 'rxjs/webSocket';
 import { WorkflowRunJobVariableComponent } from '../variables/job.variables.component';
 
@@ -104,13 +104,13 @@ export class WorkflowRunJobComponent implements OnInit, OnDestroy {
     ) {
         this.subjectChannel = new Subject<WorkflowNodeJobRun>();
         this.subscriptionChannel = this.subjectChannel.pipe(
-            mergeMap(data => from(this.onNodeJobRunChange(data)))
+            concatMap(data => from(this.onNodeJobRunChange(data)))
         ).subscribe();
     }
 
     ngOnInit(): void {
         this.pollingSpawnInfoSubscription = interval(2000)
-            .pipe(mergeMap(_ => from(this.loadSpawnInfo())))
+            .pipe(concatMap(_ => from(this.loadSpawnInfo())))
             .subscribe();
     }