docs: 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 = []