Merge pull request #116 from travis-ci/sf-notify-job-received

Notify about job:received

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"

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)