Merge branch 'master' into alec/12424-scm-perform-judge-actions-ama

app/jobs/data_integrity_checks_job.rb

@@ -20,12 +20,16 @@ def perform
     RequestStore.store[:current_user] = User.system_user
 
     CHECKERS.each do |klass|
+      checker_start_time = Time.zone.now
       checker = klass.constantize.new
       checker.call
+      datadog_report_time_segment(segment: klass.underscore, start_time: checker_start_time)
       if checker.report?
         send_to_slack(checker)
       end
     end
+
+    datadog_report_runtime(metric_group_name: "data_integrity_checks_job")
   end
 
   private

spec/jobs/data_integrity_checks_job_spec.rb

@@ -26,11 +26,35 @@
       allow(checker).to receive(:report).and_call_original
     end
     allow(slack_service).to receive(:send_notification).and_return(true)
+
+    @emitted_gauges = []
+    allow(DataDogService).to receive(:emit_gauge) do |args|
+      @emitted_gauges.push(args)
+    end
   end
 
   describe "#perform" do
+    subject { described_class.perform_now }
+
+    it "updates DataDog" do
+      subject
+
+      expect(@emitted_gauges).to include(
+        app_name: "caseflow_job",
+        metric_group: "data_integrity_checks_job",
+        metric_name: "runtime",
+        metric_value: anything
+      )
+      expect(@emitted_gauges).to include(
+        app_name: "caseflow_job_segment",
+        metric_group: "expired_async_jobs_checker",
+        metric_name: "runtime",
+        metric_value: anything
+      )
+    end
+
     it "does not send slack notifications unless there is a report" do
-      described_class.perform_now
+      subject
 
       expect(expired_async_jobs_checker).to have_received(:call).once
       expect(expired_async_jobs_checker).to have_received(:report?).once
@@ -57,7 +81,7 @@
       end
 
       it "sends slack notification if there is a report" do
-        described_class.perform_now
+        subject
 
         expect(expired_async_jobs_checker).to have_received(:call).once
         expect(expired_async_jobs_checker).to have_received(:report?).once