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 = []
call the Aspera sdk to freeup resources