diff --git a/server/executor/default_poller_executor.go b/server/executor/default_poller_executor.go
index 50f858bf26..8891e9e652 100644
--- 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")
+}