(self, partition_table, retention_period, partition_period)
return res
Test partition name of partition-by-date parent table.
Test partition name of partition-by-date parent table.
Test partition name of partition - by - date parent table .
def is_obsolete_partition (self, partition_table, retention_period, partition_period):
        """ Test partition name of partition-by-date parent table.
        """
        curs = self.dst_curs
        func = "londiste.is_obsolete_partition"
        args = [partition_table, retention_period, partition_period]
        sql = "select " + func + " (%s, %s, %s)"
        self.log.debug("func: %s, args: %s", func, args)
        curs.execute(sql, args)
        res = curs.fetchone()[0]
        if res:
            self.log.info("Ignored table: %s", partition_table)
        return res
def is_obsolete_partition ( self , partition_table , retention_period , partition_period ) : curs = self . dst_curs func = "londiste.is_obsolete_partition" args = [ partition_table , retention_period , partition_period ] sql = "select " + func + " (%s, %s, %s)" self . log . debug ( "func: %s, args: %s" , func , args ) curs . execute ( sql , args ) res = curs . fetchone ( ) [ 0 ] if res : self . log . info ( "Ignored table: %s" , partition_table ) return res