diff --git a/components/orchestration/internal/storage/migrations.go b/components/orchestration/internal/storage/migrations.go index 98d049a450..2e5ca4bb50 100644 --- a/components/orchestration/internal/storage/migrations.go +++ b/components/orchestration/internal/storage/migrations.go @@ -72,7 +72,7 @@ func registerMigrations(migrator *migrations.Migrator) { migrations.Migration{ Up: func(tx bun.Tx) error { if _, err := tx.Exec(` - alter table "workflows" add column deleted_at timestamp default null; + alter table "workflows" add column if not exists deleted_at timestamp default null; `); err != nil { return err }