docs: def _run_queued_callbacks(self):
          ''' run the init/quued calback when the trasnfer is initiated on apsera '''
          for callback in self._queued_callbacks:
              try:
                  callback()
              except Exception as ex:
                  logger.error("Exception: %s" % str(ex))