def free_processed_queue(self):
        ''' call the Aspera sdk to freeup resources '''
        with self._lock:
            if len(self._processed_coordinators) > 0:
                for _coordinator in self._processed_coordinators:
                    _coordinator.free_resources()
                self._processed_coordinators = []
def free_processed_queue ( self ) : with self . _lock : if len ( self . _processed_coordinators ) > 0 : for _coordinator in self . _processed_coordinators : _coordinator . free_resources ( ) self . _processed_coordinators = [ ]
call the Aspera sdk to freeup resources