self.log.info("Created table: %s", dst)
if self.conf.retention_period:
- self.drop_obsolete_partitions (self.dest_table, self.conf.retention_period, self.conf.period)
- if self.conf.ignore_old_events and not skytools.exists_table(curs, dst):
- self.ignored_tables.add(dst) # must have been just dropped
- if dst in self.row_handler.table_map:
- del self.row_handler.table_map[dst]
+ dropped = self.drop_obsolete_partitions (self.dest_table, self.conf.retention_period, self.conf.period)
+ if self.conf.ignore_old_events and dropped:
+ for tbl in dropped:
+ self.ignored_tables.add(tbl)
+ if tbl in self.row_handler.table_map:
+ del self.row_handler.table_map[tbl]
def drop_obsolete_partitions (self, parent_table, retention_period, partition_period):
""" Drop obsolete partitions of partition-by-date parent table.
res.append(row[0])
if res:
self.log.info("Dropped tables: %s", ", ".join(res))
+ return res
def get_copy_condition(self, src_curs, dst_curs):
""" Prepare where condition for copy and replay filtering.
londiste.handler.load_handler_modules(self.cf)
def init_optparse(self, parser=None):
- """Add londiste switches to cascadeadmin ones."""
+ """Add londiste switches to CascadeAdmin ones."""
p = CascadeAdmin.init_optparse(self, parser)
p.add_option("--expect-sync", action="store_true", dest="expect_sync",