745 add a "bytechef_job_execution" counter metric that is indexed by job name and job execution status

Author: matijapetanjek

server/libs/platform/platform-coordinator/src/main/java/com/bytechef/platform/coordinator/config/PlatformCoordinatorConfiguration.java

@@ -24,7 +24,11 @@
 import com.bytechef.platform.coordinator.event.listener.JobStatusApplicationEventListener;
 import com.bytechef.platform.coordinator.event.listener.WebhookJobStatusApplicationEventListener;
 import com.bytechef.platform.coordinator.event.listener.WebhookTaskStartedApplicationEventListener;
+import com.bytechef.platform.coordinator.metrics.JobExecutionCounter;
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
+import io.micrometer.core.instrument.MeterRegistry;
+import java.util.Optional;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -43,14 +47,21 @@ public class PlatformCoordinatorConfiguration {
     @SuppressFBWarnings("EI")
     public PlatformCoordinatorConfiguration(
         JobService jobService, NotificationHandlerRegistry notificationHandlerRegistry,
-        NotificationSenderRegistry notificationSenderRegistry, NotificationService notificationService) {
+        NotificationSenderRegistry notificationSenderRegistry, NotificationService notificationService,
+        MeterRegistry meterRegistry) {
 
         this.jobService = jobService;
         this.notificationHandlerRegistry = notificationHandlerRegistry;
         this.notificationSenderRegistry = notificationSenderRegistry;
         this.notificationService = notificationService;
     }
 
+    @Bean
+    @ConditionalOnProperty(name = "bytechef.observability.enabled", havingValue = "true")
+    JobExecutionCounter jobExecutionCounter(MeterRegistry meterRegistry) {
+        return new JobExecutionCounter(meterRegistry);
+    }
+
     @Bean
     WebhookJobStatusApplicationEventListener webhookJobStatusApplicationEventListener() {
         return new WebhookJobStatusApplicationEventListener(jobService);
@@ -62,9 +73,12 @@ WebhookTaskStartedApplicationEventListener taskStartedWebhookEventListener() {
     }
 
     @Bean
-    JobStatusApplicationEventListener jobStatusApplicationEventListener() {
+    JobStatusApplicationEventListener jobStatusApplicationEventListener(
+        Optional<JobExecutionCounter> jobExecutionCounter) {
+
         return new JobStatusApplicationEventListener(
-            jobService, notificationHandlerRegistry, notificationSenderRegistry, notificationService);
+            jobExecutionCounter, jobService, notificationHandlerRegistry, notificationSenderRegistry,
+            notificationService);
     }
 
 }

server/libs/platform/platform-coordinator/src/main/java/com/bytechef/platform/coordinator/event/listener/JobStatusApplicationEventListener.java

@@ -29,31 +29,33 @@
 import com.bytechef.platform.configuration.notification.NotificationSender;
 import com.bytechef.platform.configuration.notification.NotificationSenderRegistry;
 import com.bytechef.platform.configuration.service.NotificationService;
+import com.bytechef.platform.coordinator.metrics.JobExecutionCounter;
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
 import java.util.List;
-import org.springframework.stereotype.Component;
+import java.util.Optional;
 
 /**
  * @author Matija Petanjek
  */
-@Component
 public class JobStatusApplicationEventListener implements ApplicationEventListener {
 
+    private final Optional<JobExecutionCounter> jobExecutionCounter;
     private final JobService jobService;
     private final NotificationHandlerRegistry notificationHandlerRegistry;
     private final NotificationSenderRegistry notificationSenderRegistry;
     private final NotificationService notificationService;
 
     @SuppressFBWarnings("EI")
     public JobStatusApplicationEventListener(
-        JobService jobService, NotificationHandlerRegistry notificationHandlerRegistry,
+        Optional<JobExecutionCounter> jobExecutionCounter, JobService jobService,
+        NotificationHandlerRegistry notificationHandlerRegistry,
         NotificationSenderRegistry notificationSenderRegistry, NotificationService notificationService) {
 
+        this.jobExecutionCounter = jobExecutionCounter;
         this.jobService = jobService;
         this.notificationHandlerRegistry = notificationHandlerRegistry;
         this.notificationService = notificationService;
         this.notificationSenderRegistry = notificationSenderRegistry;
-
     }
 
     @SuppressWarnings({
@@ -62,13 +64,18 @@ public JobStatusApplicationEventListener(
     public void onApplicationEvent(ApplicationEvent applicationEvent) {
         if (applicationEvent instanceof JobStatusApplicationEvent jobStatusApplicationEvent) {
 
+            Job job = jobService.getJob(jobStatusApplicationEvent.getJobId());
+
+            jobExecutionCounter.ifPresent(
+                jobExecutionCounter -> jobExecutionCounter.process(jobStatusApplicationEvent, job));
+
             Job.Status status = jobStatusApplicationEvent.getStatus();
 
             NotificationEvent.Type eventType =
                 NotificationEvent.Type.of(NotificationEvent.Source.JOB, status.toString());
 
             NotificationHandlerContext notificationHandlerContext = getNotificationHandlerContext(
-                eventType, jobService.getJob(jobStatusApplicationEvent.getJobId()));
+                eventType, job);
 
             List<Notification> notifications = notificationService.getNotifications(eventType);
 

server/libs/platform/platform-coordinator/src/main/java/com/bytechef/platform/coordinator/metrics/JobExecutionCounter.java

@@ -0,0 +1,45 @@
+/*
+ * Copyright 2025 ByteChef
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.bytechef.platform.coordinator.metrics;
+
+import com.bytechef.atlas.coordinator.event.JobStatusApplicationEvent;
+import com.bytechef.atlas.execution.domain.Job;
+import io.micrometer.core.instrument.Counter;
+import io.micrometer.core.instrument.MeterRegistry;
+
+/**
+ * @author Matija Petanjek
+ */
+public class JobExecutionCounter {
+    private final MeterRegistry meterRegistry;
+
+    public JobExecutionCounter(MeterRegistry meterRegistry) {
+        this.meterRegistry = meterRegistry;
+    }
+
+    public void process(JobStatusApplicationEvent jobStatusApplicationEvent, Job job) {
+        Counter
+            .builder("bytechef_job_execution")
+            .tag("job_name", job.getLabel())
+            .tag("job_status", jobStatusApplicationEvent.getStatus()
+                .toString()
+                .toLowerCase())
+            .description("Inspect how many 'started' jobs ended with 'completed', 'stopped' or 'failed' status")
+            .register(meterRegistry)
+            .increment();
+    }
+}