Fix prometheus metrics (#6034)

smartcontractkit · Feb 18, 2022 · c1c0d1d · c1c0d1d
1 parent 2d81c8e
commit c1c0d1d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/services/offchainreporting2/delegate.go b/core/services/offchainreporting2/delegate.go
@@ -151,6 +151,12 @@ func (d Delegate) ServicesForSpec(jobSpec job.Job) (services []job.Service, err
 		}
 
 		runResults := make(chan pipeline.Run, d.cfg.JobPipelineResultWriteQueueDepth())
+
+		// These are populated here because when the pipeline spec is
+		// run it uses them to create identifiable prometheus metrics.
+		jobSpec.PipelineSpec.JobName = jobSpec.Name.ValueOrZero()
+		jobSpec.PipelineSpec.JobID = jobSpec.ID
+
 		juelsPerFeeCoinPipelineSpec := pipeline.Spec{
 			ID:           jobSpec.ID,
 			DotDagSource: spec.JuelsPerFeeCoinPipeline,
@@ -169,8 +175,6 @@ func (d Delegate) ServicesForSpec(jobSpec job.Job) (services []job.Service, err
 			Logger:                    ocrLogger,
 		}
 
-		jobSpec.PipelineSpec.JobName = jobSpec.Name.ValueOrZero()
-		jobSpec.PipelineSpec.JobID = jobSpec.ID
 		oracle, err := libocr2.NewOracle(libocr2.OracleArgs{
 			BinaryNetworkEndpointFactory: peerWrapper.Peer2,
 			V2Bootstrappers:              bootstrapPeers,