Skip to content

Commit

Permalink
fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
danielbdias committed Sep 12, 2023
1 parent ea21a29 commit 1c9687a
Showing 2 changed files with 4 additions and 3 deletions.
2 changes: 1 addition & 1 deletion server/executor/trace_poller.go
Original file line number Diff line number Diff line change
@@ -100,7 +100,7 @@ func (tp tracePoller) enqueueJob(ctx context.Context, job Job) {
tp.inputQueue.Enqueue(ctx, job)
}

func (tp *tracePoller) SetOutputQueue(queue Enqueuer) {
func (tp *tracePoller) SetOutputQueue(queue pipeline.Enqueuer[Job]) {
tp.outputQueue = queue
}

5 changes: 3 additions & 2 deletions server/executor/trace_poller_start_worker.go
Original file line number Diff line number Diff line change
@@ -5,11 +5,12 @@ import (
"log"

"github.com/kubeshop/tracetest/server/model/events"
"github.com/kubeshop/tracetest/server/pkg/pipeline"
)

type tracePollerStartWorker struct {
eventEmitter EventEmitter
outputQueue Enqueuer
outputQueue pipeline.Enqueuer[Job]
}

func NewTracePollerStartWorker(
@@ -20,7 +21,7 @@ func NewTracePollerStartWorker(
}
}

func (w *tracePollerStartWorker) SetOutputQueue(queue Enqueuer) {
func (w *tracePollerStartWorker) SetOutputQueue(queue pipeline.Enqueuer[Job]) {
w.outputQueue = queue
}

0 comments on commit 1c9687a

Please sign in to comment.