#801: Not triggered workflows (#814)

jozefbakus · web-flow · commit 08bc5a082340 · 2023-09-19T16:30:15.000+02:00
diff --git a/src/main/scala/za/co/absa/hyperdrive/trigger/scheduler/JobScheduler.scala b/src/main/scala/za/co/absa/hyperdrive/trigger/scheduler/JobScheduler.scala
@@ -97,6 +97,7 @@ class JobScheduler @Inject() (
         .recover { case e: SchedulerInstanceAlreadyDeactivatedException =>
           logger.warn("Restarting scheduler because the instance has been deactivated by other instance", e)
           cleanUp()
+          sensors.prepareSensors()
           throw e
         }
         .map(_.map(_.id))

Original file line number	Diff line number	Diff line change
`@@ -97,6 +97,7 @@ class JobScheduler @Inject() (`
`97`	`97`	`.recover { case e: SchedulerInstanceAlreadyDeactivatedException =>`
`98`	`98`	`logger.warn("Restarting scheduler because the instance has been deactivated by other instance", e)`
`99`	`99`	`cleanUp()`
	`100`	`+ sensors.prepareSensors()`
`100`	`101`	`throw e`
`101`	`102`	`}`
`102`	`103`	`.map(_.map(_.id))`