From 4f91221e6524ffe886ad5acbc4c9b12141ec2c80 Mon Sep 17 00:00:00 2001
From: Daniel Dias <danielbpdias@gmail.com>
Date: Fri, 15 Sep 2023 15:21:13 -0300
Subject: [PATCH] Fixing worked enabled condition

---
 server/executor/tracepollerworker/fetcher_worker.go | 1 -
 server/executor/trigger_executer_worker.go          | 1 -
 2 files changed, 2 deletions(-)

diff --git a/server/executor/tracepollerworker/fetcher_worker.go b/server/executor/tracepollerworker/fetcher_worker.go
index 9456e046a0..1c18b42862 100644
--- 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
index 3f1e065c50..bcd9c35a00 100644
--- 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
 	}