Delete expired instances

cschleiden · Nov 4, 2023 · 3fcac68 · 3fcac68
1 parent 711622e
commit 3fcac68
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/backend/sqlite/sqlite.go b/backend/sqlite/sqlite.go
@@ -242,6 +242,10 @@ func (sb *sqliteBackend) RemoveWorkflowInstance(ctx context.Context, instance *c
 		return err
 	}
 
+	if _, err := tx.ExecContext(ctx, "DELETE FROM `attributes` WHERE instance_id = ? AND execution_id = ?", instanceID, executionID); err != nil {
+		return err
+	}
+
 	return tx.Commit()
 }