|
|
|
@ -681,26 +681,6 @@ public final class JobRunner: JobRunnerType {
|
|
|
|
|
|
|
|
|
|
queues.wrappedValue[job.variant]?.removePendingJob(jobId)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//public static func hasPendingOrRunningJob<T: Encodable>(
|
|
|
|
|
// with variant: Job.Variant,
|
|
|
|
|
// threadId: String? = nil,
|
|
|
|
|
// interactionId: Int64? = nil,
|
|
|
|
|
// details: T? = nil
|
|
|
|
|
//) -> Bool {
|
|
|
|
|
// guard let targetQueue: JobQueue = queues.wrappedValue[variant] else { return false }
|
|
|
|
|
//
|
|
|
|
|
// // Ensure we can encode the details (if provided)
|
|
|
|
|
// let detailsData: Data? = details.map { try? JSONEncoder().encode($0) }
|
|
|
|
|
//
|
|
|
|
|
// guard details == nil || detailsData != nil else { return false }
|
|
|
|
|
//
|
|
|
|
|
// return targetQueue.hasPendingOrRunningJobWith(
|
|
|
|
|
// threadId: threadId,
|
|
|
|
|
// interactionId: interactionId,
|
|
|
|
|
// detailsData: detailsData
|
|
|
|
|
// )
|
|
|
|
|
//}
|
|
|
|
|
|
|
|
|
|
// MARK: - Convenience
|
|
|
|
|
|
|
|
|
|