@@ -25,11 +25,11 @@ struct CreateSwiftJobsMigrations: DatabaseMigration {
25
25
try await connection. query (
26
26
"""
27
27
CREATE TABLE IF NOT EXISTS swift_jobs.jobs (
28
- id uuid PRIMARY KEY,
29
- job bytea NOT NULL,
28
+ id UUID PRIMARY KEY,
29
+ job BYTEA NOT NULL,
30
30
last_modified TIMESTAMPTZ NOT NULL DEFAULT now(),
31
31
queue_name TEXT NOT NULL DEFAULT 'default',
32
- status smallint NOT NULL
32
+ status SMALLINT NOT NULL
33
33
);
34
34
""" ,
35
35
logger: logger
@@ -38,7 +38,7 @@ struct CreateSwiftJobsMigrations: DatabaseMigration {
38
38
try await connection. query (
39
39
"""
40
40
CREATE TABLE IF NOT EXISTS swift_jobs.queues(
41
- job_id uuid PRIMARY KEY,
41
+ job_id UUID PRIMARY KEY,
42
42
created_at TIMESTAMPTZ NOT NULL,
43
43
delayed_until TIMESTAMPTZ NOT NULL DEFAULT now(),
44
44
queue_name TEXT NOT NULL DEFAULT 'default',
@@ -50,7 +50,7 @@ struct CreateSwiftJobsMigrations: DatabaseMigration {
50
50
51
51
try await connection. query (
52
52
"""
53
- CREATE INDEX CONCURRENTLY IF NOT EXISTS queues_delayed_until_priority_queue_name_idx
53
+ CREATE INDEX IF NOT EXISTS queues_delayed_until_priority_queue_name_idx
54
54
ON swift_jobs.queues(priority DESC, delayed_until ASC, queue_name ASC)
55
55
""" ,
56
56
logger: logger
@@ -59,8 +59,8 @@ struct CreateSwiftJobsMigrations: DatabaseMigration {
59
59
try await connection. query (
60
60
"""
61
61
CREATE TABLE IF NOT EXISTS swift_jobs.queues_metadata(
62
- key text PRIMARY KEY,
63
- value bytea NOT NULL,
62
+ key TEXT PRIMARY KEY,
63
+ value BYTEA NOT NULL,
64
64
queue_name TEXT NOT NULL DEFAULT 'default'
65
65
)
66
66
""" ,
@@ -69,7 +69,7 @@ struct CreateSwiftJobsMigrations: DatabaseMigration {
69
69
70
70
try await connection. query (
71
71
"""
72
- CREATE INDEX CONCURRENTLY IF NOT EXISTS queues_metadata_key_queue_name_idx
72
+ CREATE INDEX IF NOT EXISTS queues_metadata_key_queue_name_idx
73
73
ON swift_jobs.queues_metadata(key, queue_name)
74
74
""" ,
75
75
logger: logger
0 commit comments