def prune(self, connection):
        query = "delete from %s where %s >= %s" % (self.prune_table, self.prune_column, self.prune_date)
        cursor = connection.cursor()
        try:
            cursor.execute(query)
        finally:
            cursor.close()
dataset/ETHPy150Open spotify/luigi/luigi/contrib/redshift.py/S3CopyToTable.prune/original