docs: def submit(self, data, runtime_dir, argv):
          """Run process.
  
          For details, see
          :meth:`~resolwe.flow.managers.workload_connectors.base.BaseConnector.submit`.
          """
          queue = 'ordinary'
          if data.process.scheduling_class == Process.SCHEDULING_CLASS_INTERACTIVE:
              queue = 'hipri'
  
          logger.debug(__(
              "Connector '{}' running for Data with id {} ({}) in celery queue {}, EAGER is {}.",
              self.__class__.__module__,
              data.id,
              repr(argv),
              queue,
              getattr(settings, 'CELERY_ALWAYS_EAGER', None)
          ))
          celery_run.apply_async((data.id, runtime_dir, argv), queue=queue)