From 53462d90671dbce5e402d38644791a19eb55b720 Mon Sep 17 00:00:00 2001 From: Zanoroy Date: Mon, 8 Aug 2022 09:58:35 +0930 Subject: [PATCH] Update Job Migration to use a json field rather than a bytea --- Sources/QueuesFluentDriver/JobModelMigrate.swift | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/Sources/QueuesFluentDriver/JobModelMigrate.swift b/Sources/QueuesFluentDriver/JobModelMigrate.swift index b9cdbb8..3920d82 100644 --- a/Sources/QueuesFluentDriver/JobModelMigrate.swift +++ b/Sources/QueuesFluentDriver/JobModelMigrate.swift @@ -4,17 +4,17 @@ import SQLKit public struct JobModelMigrate: Migration { public init() {} - + public init(schema: String) { JobModel.schema = schema } - + public func prepare(on database: Database) -> EventLoopFuture { return database.schema(JobModel.schema) .id() .field(FieldKey.jobId, .string, .required) .field(FieldKey.queue, .string, .required) - .field(FieldKey.data, .data, .required) + .field(FieldKey.data, .json, .required) .field(FieldKey.state, .string, .required) .field(FieldKey.createdAt, .datetime) .field(FieldKey.updatedAt, .datetime) @@ -42,7 +42,7 @@ public struct JobModelMigrate: Migration { } } } - + public func revert(on database: Database) -> EventLoopFuture { return database.schema(JobModel.schema).delete() }