Merge pull request #18 from hummingbird-project/metadata-read

hummingbird-project · Aug 29, 2024 · 84dc086 · 84dc086
2 parents e40ea83 + 5070ec1
commit 84dc086
Showing 1 changed file with 8 additions and 9 deletions.
diff --git a/Sources/Jobs/Scheduler/JobSchedule.swift b/Sources/Jobs/Scheduler/JobSchedule.swift
@@ -160,7 +160,13 @@ public struct JobSchedule: MutableCollection, Sendable {
 
         init(jobQueue: JobQueue<Driver>, jobSchedule: JobSchedule) async {
             self.jobQueue = jobQueue
-            var jobSchedule = jobSchedule
+            self.jobSchedule = jobSchedule
+        }
+
+        /// Run Job scheduler
+        public func run() async throws {
+            try await self.jobQueue.initializationComplete.waitUntilTriggered()
+            var jobSchedule = self.jobSchedule
             // Update next scheduled date for each job schedule based off the last scheduled date stored
             do {
                 if let date = try await self.jobQueue.getMetadata(.jobScheduleLastDate) {
@@ -171,15 +177,8 @@ public struct JobSchedule: MutableCollection, Sendable {
             } catch {
                 self.jobQueue.logger.error("Failed to get last scheduled job date.")
             }
-
-            self.jobSchedule = jobSchedule
-        }
-
-        /// Run Job scheduler
-        public func run() async throws {
-            try await self.jobQueue.initializationComplete.waitUntilTriggered()
             let scheduledJobSequence = JobSequence(
-                jobSchedule: self.jobSchedule,
+                jobSchedule: jobSchedule,
                 logger: self.jobQueue.logger
             )
             for await job in scheduledJobSequence.cancelOnGracefulShutdown() {