migrations: squash migrations into a single file

Author: vr009

backend/postgres/db/migrations/000001_initial.down.sql

@@ -1,3 +1,4 @@
+DROP TABLE IF EXISTS attributes;
 DROP TABLE IF EXISTS instances;
 DROP TABLE IF EXISTS pending_events;
 DROP TABLE IF EXISTS history;

backend/postgres/db/migrations/000001_initial.up.sql

@@ -9,6 +9,7 @@ CREATE TABLE instances (
   parent_schedule_event_id numeric NULL,
   metadata bytea NULL,
   state int NOT NULL,
+  queue varchar(128) DEFAULT '' NOT NULL,
   created_at timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP,
   completed_at timestamptz NULL,
   locked_until timestamptz NULL,
@@ -17,7 +18,7 @@ CREATE TABLE instances (
 );
 
 CREATE UNIQUE INDEX idx_instances_instance_id_execution_id on instances (instance_id, execution_id);
-CREATE INDEX idx_instances_locked_until_completed_at on instances (completed_at, locked_until, sticky_until, worker);
+CREATE INDEX idx_instances_locked_until_completed_at_queue ON instances (completed_at, locked_until, sticky_until, worker, queue);
 CREATE INDEX idx_instances_parent_instance_id_parent_execution_id ON instances (parent_instance_id, parent_execution_id);
 
 DROP TABLE IF EXISTS pending_events;
@@ -30,7 +31,6 @@ CREATE TABLE pending_events (
   event_type int NOT NULL,
   timestamp timestamptz NOT NULL,
   schedule_event_id bigserial NOT NULL,
-  attributes bytea NOT NULL,
   visible_at timestamptz NULL
 );
 
@@ -47,7 +47,6 @@ CREATE TABLE IF NOT EXISTS history (
   event_type int NOT NULL,
   timestamp timestamptz NOT NULL,
   schedule_event_id bigserial NOT NULL,
-  attributes bytea NOT NULL,
   visible_at timestamptz NULL
 );
 
@@ -61,13 +60,25 @@ CREATE TABLE IF NOT EXISTS activities (
   instance_id varchar(128) NOT NULL,
   execution_id varchar(128) NOT NULL,
   event_type int NOT NULL,
+  queue varchar(128) DEFAULT '' NOT NULL,
   timestamp timestamptz NOT NULL,
   schedule_event_id bigserial NOT NULL,
-  attributes bytea NOT NULL,
   visible_at timestamptz NULL,
   locked_until timestamptz NULL,
   worker VARCHAR(64) NULL
 );
 
 CREATE UNIQUE INDEX idx_activities_instance_id_execution_id_activity_id_worker ON activities (instance_id, execution_id, activity_id, worker);
-CREATE INDEX idx_activities_locked_until on activities (locked_until);
+CREATE INDEX idx_activities_locked_until_queue ON activities (locked_until, queue);
+
+DROP TABLE IF EXISTS attributes;
+CREATE TABLE attributes (
+  id BIGSERIAL NOT NULL PRIMARY KEY,
+  event_id varchar(128) NOT NULL,
+  instance_id varchar(128) NOT NULL,
+  execution_id varchar(128) NOT NULL,
+  data bytea NOT NULL
+);
+
+CREATE UNIQUE INDEX idx_attributes_instance_id_execution_id_event_id on attributes (instance_id, execution_id, event_id);
+CREATE INDEX idx_attributes_event_id on attributes (event_id);