HTM-1227: allow monitoring of triggered jobs through Sentry (#990)

Tailormap · Oct 14, 2024 · eb34790 · eb34790
1 parent 85e9cce
commit eb34790
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 0 deletions.
diff --git a/pom.xml b/pom.xml
@@ -499,6 +499,11 @@ SPDX-License-Identifier: MIT
             <artifactId>sentry-jdbc</artifactId>
             <version>${sentry.version}</version>
         </dependency>
+        <dependency>
+            <groupId>io.sentry</groupId>
+            <artifactId>sentry-quartz</artifactId>
+            <version>${sentry.version}</version>
+        </dependency>
         <dependency>
             <groupId>io.sentry</groupId>
             <artifactId>sentry</artifactId>

diff --git a/src/main/java/org/tailormap/api/configuration/SchedulerConfiguration.java b/src/main/java/org/tailormap/api/configuration/SchedulerConfiguration.java
@@ -5,6 +5,7 @@
  */
 package org.tailormap.api.configuration;
 
+import io.sentry.quartz.SentryJobListener;
 import jakarta.annotation.PostConstruct;
 import java.lang.invoke.MethodHandles;
 import org.quartz.SchedulerException;
@@ -29,6 +30,10 @@ public SchedulerConfiguration(@Autowired SchedulerFactoryBean schedulerFactoryBe
 
   @PostConstruct
   public void addListeners() throws SchedulerException {
+    schedulerFactoryBean
+        .getScheduler()
+        .getListenerManager()
+        .addJobListener(new SentryJobListener());
     if (logger.isDebugEnabled()) {
       // Add debug logging listeners to the scheduler
       schedulerFactoryBean

diff --git a/src/main/java/org/tailormap/api/scheduling/TaskCreator.java b/src/main/java/org/tailormap/api/scheduling/TaskCreator.java
@@ -5,6 +5,8 @@
  */
 package org.tailormap.api.scheduling;
 
+import static io.sentry.quartz.SentryJobListener.SENTRY_SLUG_KEY;
+
 import java.lang.invoke.MethodHandles;
 import java.util.UUID;
 import org.quartz.CronScheduleBuilder;
@@ -62,6 +64,7 @@ public String createTask(
             .withIdentity(jobDetail.getKey().getName(), jobDetail.getKey().getGroup())
             .startAt(DateBuilder.futureDate(30, DateBuilder.IntervalUnit.SECOND))
             .withPriority(jobData.getPriority())
+            .usingJobData(SENTRY_SLUG_KEY, "monitor_slug_cron_trigger_" + jobData.get("type"))
             .withSchedule(
                 CronScheduleBuilder.cronSchedule(cronExpression)
                     .withMisfireHandlingInstructionFireAndProceed())