Raise create work flow isolation back to Serializable

Signed-off-by: Ryan Li <[email protected]>
tinkerbell · Oct 23, 2020 · 084b6cc · 084b6cc
1 parent 3b230d5
commit 084b6cc
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/db/workflow.go b/db/workflow.go
@@ -33,7 +33,7 @@ var (
 
 // CreateWorkflow creates a new workflow
 func (d TinkDB) CreateWorkflow(ctx context.Context, wf Workflow, data string, id uuid.UUID) error {
-	tx, err := d.instance.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelRepeatableRead})
+	tx, err := d.instance.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelSerializable})
 	if err != nil {
 		return errors.Wrap(err, "BEGIN transaction")
 	}

diff --git a/deploy/db/tinkerbell-init.sql b/deploy/db/tinkerbell-init.sql
@@ -68,6 +68,8 @@ CREATE TABLE IF NOT EXISTS workflow_worker_map (
         , worker_id UUID NOT NULL
 );
 
+CREATE UNIQUE INDEX IF NOT EXISTS uidx_workflow_worker_map ON workflow_worker_map (workflow_id, worker_id);
+
 CREATE TABLE IF NOT EXISTS workflow_data (
         workflow_id UUID NOT NULL
         , version INT