diff options
Diffstat (limited to 'scripts')
| -rwxr-xr-x | scripts/bulk_loader.py | 1 | ||||
| -rwxr-xr-x | scripts/cube_dispatcher.py | 2 | ||||
| -rwxr-xr-x | scripts/queue_loader.py | 1 | ||||
| -rwxr-xr-x | scripts/queue_mover.py | 1 | ||||
| -rwxr-xr-x | scripts/queue_splitter.py | 1 | ||||
| -rwxr-xr-x | scripts/simple_serial_consumer.py | 1 | ||||
| -rwxr-xr-x | scripts/table_dispatcher.py | 2 |
7 files changed, 0 insertions, 9 deletions
diff --git a/scripts/bulk_loader.py b/scripts/bulk_loader.py index 60852bea..c9a67496 100755 --- a/scripts/bulk_loader.py +++ b/scripts/bulk_loader.py @@ -253,7 +253,6 @@ class BulkLoader(pgq.SerialConsumer): tables[tbl] = TableCache(tbl) cache = tables[tbl] cache.add_event(ev) - ev.tag_done() # then process them for tbl, cache in tables.items(): diff --git a/scripts/cube_dispatcher.py b/scripts/cube_dispatcher.py index 9bd8fc3e..76a3ab3f 100755 --- a/scripts/cube_dispatcher.py +++ b/scripts/cube_dispatcher.py @@ -90,8 +90,6 @@ class CubeDispatcher(pgq.SerialConsumer): if not tbl in tables: tables[tbl] = self.get_table_info(ev, tbl) - ev.tag_done() - # create tables if needed self.check_tables(dst_db, tables) diff --git a/scripts/queue_loader.py b/scripts/queue_loader.py index c71b20e9..1b3090df 100755 --- a/scripts/queue_loader.py +++ b/scripts/queue_loader.py @@ -593,7 +593,6 @@ class QueueLoader(CascadedWorker): self.init_state(tbl) st = self.table_state[tbl] st.add(dst_curs, ev, self._batch_info) - ev.tag_done() def finish_remote_batch(self, src_db, dst_db, tick_id): curs = dst_db.cursor() diff --git a/scripts/queue_mover.py b/scripts/queue_mover.py index 6c0556d6..92fe5370 100755 --- a/scripts/queue_mover.py +++ b/scripts/queue_mover.py @@ -35,7 +35,6 @@ class QueueMover(pgq.SerialConsumer): for ev in ev_list: data = [ev.type, ev.data, ev.extra1, ev.extra2, ev.extra3, ev.extra4, ev.time] rows.append(data) - ev.tag_done() fields = ['type', 'data', 'extra1', 'extra2', 'extra3', 'extra4', 'time'] # insert data 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'] diff --git a/scripts/simple_serial_consumer.py b/scripts/simple_serial_consumer.py index 0c771954..2bd06be7 100755 --- a/scripts/simple_serial_consumer.py +++ b/scripts/simple_serial_consumer.py @@ -87,7 +87,6 @@ class SimpleSerialConsumer(pgq.SerialConsumer): self.log.debug(res) except: pass - ev.tag_done() if __name__ == '__main__': script = SimpleSerialConsumer(sys.argv[1:]) diff --git a/scripts/table_dispatcher.py b/scripts/table_dispatcher.py index b4fd2d10..52cd2b7b 100755 --- a/scripts/table_dispatcher.py +++ b/scripts/table_dispatcher.py @@ -104,8 +104,6 @@ class TableDispatcher(pgq.SerialConsumer): else: tables[tbl].append(dstrow) - ev.tag_done() - # create tables if needed self.check_tables(dst_db, tables) |