Fixing worked enabled condition

kubeshop · Sep 15, 2023 · 4f91221 · 4f91221
1 parent 24adb72
commit 4f91221
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/server/executor/tracepollerworker/fetcher_worker.go b/server/executor/tracepollerworker/fetcher_worker.go
@@ -50,7 +50,6 @@ func (w *traceFetcherWorker) SetOutputQueue(queue pipeline.Enqueuer[executor.Job
 
 func (w *traceFetcherWorker) ProcessItem(ctx context.Context, job executor.Job) {
 	if !w.enabled {
-		w.outputQueue.Enqueue(ctx, job)
 		return
 	}
 

diff --git a/server/executor/trigger_executer_worker.go b/server/executor/trigger_executer_worker.go
@@ -59,7 +59,6 @@ func (r triggerExecuterWorker) handleError(run test.Run, err error) {
 
 func (r triggerExecuterWorker) ProcessItem(ctx context.Context, job Job) {
 	if !r.enabled {
-		r.outputQueue.Enqueue(ctx, job)
 		return
 	}
-Original file line number
+Diff line change
@@ Expand Up @@
     func (w *traceFetcherWorker) ProcessItem(ctx context.Context, job executor.Job) {
     	if !w.enabled {
-    		w.outputQueue.Enqueue(ctx, job)
     		return
     	}
@@ Expand Down @@