From d3213b64bb42275570eca4a842a774a8fb15b4ce Mon Sep 17 00:00:00 2001 From: -LAN- Date: Thu, 19 Jun 2025 17:20:29 +0800 Subject: [PATCH] fix(migration): correct the sequence_number Signed-off-by: -LAN- --- ...e1cc7fa_remove_sequence_number_from_workflow_.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/api/migrations/versions/2025_06_19_1633-0ab65e1cc7fa_remove_sequence_number_from_workflow_.py b/api/migrations/versions/2025_06_19_1633-0ab65e1cc7fa_remove_sequence_number_from_workflow_.py index 5f9c6265b7..b1516660e2 100644 --- a/api/migrations/versions/2025_06_19_1633-0ab65e1cc7fa_remove_sequence_number_from_workflow_.py +++ b/api/migrations/versions/2025_06_19_1633-0ab65e1cc7fa_remove_sequence_number_from_workflow_.py @@ -38,14 +38,15 @@ def downgrade(): connection = op.get_bind() connection.execute(sa.text(""" UPDATE workflow_runs - SET sequence_number = ( - SELECT ROW_NUMBER() OVER ( + SET sequence_number = subquery.row_num + FROM ( + SELECT id, ROW_NUMBER() OVER ( PARTITION BY tenant_id, app_id ORDER BY created_at, id - ) - FROM workflow_runs wr2 - WHERE wr2.id = workflow_runs.id - ) + ) as row_num + FROM workflow_runs + ) subquery + WHERE workflow_runs.id = subquery.id """)) # Step 3: Make the column NOT NULL and add the index