diff --git a/lib/travis/worker/instance.rb b/lib/travis/worker/instance.rb
index 7b35a9aa..98d301b2 100644
--- a/lib/travis/worker/instance.rb
+++ b/lib/travis/worker/instance.rb
@@ -90,6 +90,7 @@ def work(message, payload)
         info "starting job slug:#{self.payload['repository']['slug']} id:#{self.payload['job']['id']}"
         info "this is a requeued message" if message.redelivered?
 
+        notify_job_received
         run_job
 
         finish(message)
@@ -283,6 +284,10 @@ def timeout(type)
         timeout.to_i
       end
 
+      def notify_job_received
+        reporter.notify_job_received(self.payload['job']['id'])
+      end
+
       def restart_job
         if reporter && payload['job']['id']
           info "requeuing job"
diff --git a/lib/travis/worker/reporter.rb b/lib/travis/worker/reporter.rb
index cc95985a..3c7b6caa 100644
--- a/lib/travis/worker/reporter.rb
+++ b/lib/travis/worker/reporter.rb
@@ -70,8 +70,12 @@ def send_last_log(job_id)
         send_log(job_id, "", true)
       end
 
+      def notify_job_received(job_id)
+        notify('job:test:receive', id: job_id, state: 'received', received_at: Time.now.utc, worker: Travis::Worker.config.hostname)
+      end
+
       def notify_job_started(job_id)
-        notify('job:test:start',  id: job_id, state: 'started', started_at: Time.now.utc)
+        notify('job:test:start', id: job_id, state: 'started', started_at: Time.now.utc)
       end
 
       def notify_job_finished(job_id, result)