Merge pull request #245 from taskcluster/bug1588789

Bug 1588789 - log workerReady the first time we're ready to call queue.claimWork

.taskcluster.yml

@@ -517,7 +517,7 @@ tasks:
   ############## Linux amd64 Multiuser Build ###############
   ##########################################################
 
-  - provisionerId: pmoore-test
+  - provisionerId: aws-provisioner-v1
     workerType: gwci-linux
     metadata:
       name: "Build/test 64 bit generic-worker (multiuser engine) on Ubuntu 17.04 VM"
@@ -592,7 +592,7 @@ tasks:
   ################ Linux amd64 Simple Build ################
   ##########################################################
 
-  - provisionerId: pmoore-test
+  - provisionerId: aws-provisioner-v1
     workerType: gwci-linux
     metadata:
       name: "Build/test 64 bit generic-worker (simple engine) on Ubuntu 17.04 VM"
@@ -663,7 +663,7 @@ tasks:
   ################ Linux amd64 Docker Build ################
   ##########################################################
 
-  - provisionerId: pmoore-test
+  - provisionerId: aws-provisioner-v1
     workerType: gwci-linux
     metadata:
       name: "Build/test 64 bit generic-worker (docker engine) on Ubuntu 17.04 VM"
@@ -734,7 +734,7 @@ tasks:
   ############## Check vendored dependencies ###############
   ##########################################################
 
-  - provisionerId: pmoore-test
+  - provisionerId: aws-provisioner-v1
     workerType: gwci-linux
     metadata:
       name: "Run 'dep check' to ensure dependencies are up to date"

main.go

@@ -43,6 +43,8 @@ var (
 	reclaimEvery5Seconds = false
 	// Current working directory of process
 	cwd = CwdOrPanic()
+	// workerReady becomes true when it is able to call queue.claimWork for the first time
+	workerReady = false
 	// Whether we are running under the aws provisioner
 	configureForAWS bool
 	// Whether we are running in GCP
@@ -390,7 +392,6 @@ func RunWorker() (exitCode ExitCode) {
 	if host, err := sysinfo.Host(); err == nil {
 		logEvent("instanceBoot", nil, host.Info().BootTime)
 	}
-	logEvent("workerReady", nil, time.Now())
 
 	err = setupExposer()
 	if err != nil {
@@ -541,6 +542,11 @@ func RunWorker() (exitCode ExitCode) {
 
 // ClaimWork queries the Queue to find a task.
 func ClaimWork() *TaskRun {
+	// only log workerReady the first time queue.claimWork is called
+	if !workerReady {
+		workerReady = true
+		logEvent("workerReady", nil, time.Now())
+	}
 	req := &tcqueue.ClaimWorkRequest{
 		Tasks:       1,
 		WorkerGroup: config.WorkerGroup,