Update PostgresJobsQueue.swift

thoven87 · thoven87 · commit 7b5fae1f0483 · 2025-03-18T22:53:37.000-04:00
diff --git a/Sources/JobsPostgres/PostgresJobsQueue.swift b/Sources/JobsPostgres/PostgresJobsQueue.swift
@@ -470,7 +470,7 @@ public final class PostgresJobQueue: JobQueueDriver, CancellableJobQueue, Resuma
     }
     /// Helper func which to be use by a scheduled jobs
     /// for performing job clean up based on a given set of policies
-    public func processDataRetentionPolicies() async throws {
+    public func processDataRetentionPolicy() async throws {
         try await self.client.withTransaction(logger: logger) { tx in
             let now = Date.now.timeIntervalSince1970
             let retentionPolicy: RetentionPolicy = configuration.retentionPolicy

Original file line number	Diff line number	Diff line change
`@@ -470,7 +470,7 @@ public final class PostgresJobQueue: JobQueueDriver, CancellableJobQueue, Resuma`
`470`	`470`	`}`
`471`	`471`	`/// Helper func which to be use by a scheduled jobs`
`472`	`472`	`/// for performing job clean up based on a given set of policies`
`473`		`- public func processDataRetentionPolicies() async throws {`
	`473`	`+ public func processDataRetentionPolicy() async throws {`
`474`	`474`	`try await self.client.withTransaction(logger: logger) { tx in`
`475`	`475`	`let now = Date.now.timeIntervalSince1970`
`476`	`476`	`let retentionPolicy: RetentionPolicy = configuration.retentionPolicy`