Added missing method

kubeshop · Sep 11, 2023 · 29ce35c · 29ce35c
1 parent a9a80aa
commit 29ce35c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/executor/default_poller_executor.go b/server/executor/default_poller_executor.go
@@ -234,3 +234,7 @@ func (pe DefaultPollerExecutor) donePollingTraces(job *Job, traceDB tracedb.Trac
 
 	return false, fmt.Sprintf("New spans found. Before: %d After: %d", len(job.Run.Trace.Flat), len(trace.Flat))
 }
+
+func isFirstRequest(job *Job) bool {
+	return !job.Headers.GetBool("requeued")
+}