giraffez/load.py
def cleanup(self):
        """
        Drops any existing work tables, as returned by
        :meth:`~giraffez.load.TeradataBulkLoad.tables`.

        :raises `giraffez.TeradataPTError`: if a Teradata error ocurred
        """
        threads = []
        for i, table in enumerate(filter(lambda x: self.mload.exists(x), self.tables)):
            log.info("BulkLoad", "Dropping table '{}'...".format(table))
            t = threading.Thread(target=self.mload.drop_table, args=(table,))
            threads.append(t)
            t.start()
        for t in threads:
            t.join()
def cleanup(self):
        """
        Drops any existing work tables, as returned by
        :meth:`~giraffez.load.TeradataBulkLoad.tables`.

        :raises `giraffez.TeradataPTError`: if a Teradata error ocurred
        """
        threads = []
        for i, table in enumerate(filter(lambda x: self.mload.exists(x), self.tables)):
            log.info("BulkLoad", "Dropping table '{}'...".format(table))
            t = threading.Thread(target=self.mload.drop_table, args=(table,))
            threads.append(t)
            t.start()
        for t in threads:
            t.join()
def cleanup ( self ) : threads = [ ] for i , table in enumerate ( filter ( lambda x : self . mload . exists ( x ) , self . tables ) ) : log . info ( "BulkLoad" , "Dropping table '{}'..." . format ( table ) ) t = threading . Thread ( target = self . mload . drop_table , args = ( table , ) ) threads . append ( t ) t . start ( ) for t in threads : t . join ( )
Drops any existing work tables, as returned by
        :meth:`~giraffez.load.TeradataBulkLoad.tables`.

        :raises `giraffez.TeradataPTError`: if a Teradata error ocurred
Drops any existing work tables as returned by : meth : ~giraffez . load . TeradataBulkLoad . tables .