diff --git a/deploy/db/spec_events.py b/deploy/db/spec_events.py index b9e765a..e23081e 100644 --- a/deploy/db/spec_events.py +++ b/deploy/db/spec_events.py @@ -17,10 +17,11 @@ def get_next_seq(contract_id): conn.autocommit = False with conn.cursor() as cur: cur.execute( - "SELECT COALESCE(MAX(seq), 0) + 1 FROM spec_events WHERE contract_id = %s FOR UPDATE", + "SELECT seq FROM spec_events WHERE contract_id = %s ORDER BY seq DESC LIMIT 1 FOR UPDATE", (contract_id,), ) - seq = cur.fetchone()[0] + row = cur.fetchone() + seq = (row[0] + 1) if row else 1 conn.commit() return seq except Exception: