diff options
Diffstat (limited to 'scripts/queue_splitter.py')
| -rwxr-xr-x | scripts/queue_splitter.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/scripts/queue_splitter.py b/scripts/queue_splitter.py index 3e43004c..13a04051 100755 --- a/scripts/queue_splitter.py +++ b/scripts/queue_splitter.py @@ -25,7 +25,7 @@ class QueueSplitter(pgq.SerialConsumer): __doc__ = __doc__ def __init__(self, args): - pgq.SerialConsumer.__init__(self, "queue_splitter", "src_db", "dst_db", args) + pgq.SerialConsumer.__init__(self, "queue_splitter3", "src_db", "dst_db", args) def process_remote_batch(self, db, batch_id, ev_list, dst_db): cache = {} |