From 90cb02e0bffd04ec02b1f9dd550cd61c11e3d66e Mon Sep 17 00:00:00 2001 From: Ryan Petrello Date: Tue, 18 Feb 2020 11:31:05 -0500 Subject: [PATCH] fix start/end line incrementing behavior --- tools/scripts/firehose.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/tools/scripts/firehose.py b/tools/scripts/firehose.py index aff0fb1e3e..f8b3435240 100755 --- a/tools/scripts/firehose.py +++ b/tools/scripts/firehose.py @@ -209,14 +209,17 @@ def generate_events(events, job): print('generating unique start/end line counts') cursor.execute('CREATE SEQUENCE IF NOT EXISTS firehose_seq;') - cursor.execute('CREATE SEQUENCE IF NOT EXISTS firehose_line_seq;') + cursor.execute('CREATE SEQUENCE IF NOT EXISTS firehose_line_seq MINVALUE 0;') + cursor.execute('ALTER SEQUENCE firehose_seq RESTART WITH 1;') + cursor.execute('ALTER SEQUENCE firehose_line_seq RESTART WITH 0;') + cursor.execute("SELECT nextval('firehose_line_seq')") conn.commit() cursor.execute( "UPDATE main_jobevent SET " "counter=nextval('firehose_seq')::integer," - "start_line=nextval('firehose_seq')::integer," - "end_line=currval('firehose_seq')::integer + 2" + "start_line=nextval('firehose_line_seq')::integer," + "end_line=currval('firehose_line_seq')::integer + 2" ) conn.commit() finally: