diff options
Diffstat (limited to 'scripts/queue_splitter.py')
| -rwxr-xr-x | scripts/queue_splitter.py | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/scripts/queue_splitter.py b/scripts/queue_splitter.py index 29ee0db0..dab23982 100755 --- a/scripts/queue_splitter.py +++ b/scripts/queue_splitter.py @@ -37,7 +37,6 @@ class QueueSplitter(pgq.SerialConsumer): if queue not in cache: cache[queue] = [] cache[queue].append(row) - ev.tag_done() # should match the composed row fields = ['type', 'data', 'extra1', 'extra2', 'extra3', 'extra4', 'time'] |