(self, tags)
:param tags:
        :return:
:param tags:
        :return:
: param tags : : return :
def run_job_loop(self, tags):
        """
        :param tags:
        :return:
        """
        if not self._enabled:
            self._log.debug("[job=%s] Job not enabled.", self._job_name)
            return
        if not self._db_hostname:
            self._db_hostname = resolve_db_host(self._config_host)
        self._tags = tags
        self._tags_str = ','.join(self._tags)
        self._job_tags = self._tags + ["job:{}".format(self._job_name)]
        self._job_tags_str = ','.join(self._job_tags)
        self._last_check_run = time.time()
        if self._run_sync or is_affirmative(os.environ.get('DBM_THREADED_JOB_RUN_SYNC', "false")):
            self._log.debug("Running threaded job synchronously. job=%s", self._job_name)
            self._run_job_rate_limited()
        elif self._job_loop_future is None or not self._job_loop_future.running():
            self._job_loop_future = DBMAsyncJob.executor.submit(self._job_loop)
        else:
            self._log.debug("Job loop already running. job=%s", self._job_name)
def run_job_loop ( self , tags ) : if not self . _enabled : self . _log . debug ( "[job=%s] Job not enabled." , self . _job_name ) return if not self . _db_hostname : self . _db_hostname = resolve_db_host ( self . _config_host ) self . _tags = tags self . _tags_str = ',' . join ( self . _tags ) self . _job_tags = self . _tags + [ "job:{}" . format ( self . _job_name ) ] self . _job_tags_str = ',' . join ( self . _job_tags ) self . _last_check_run = time . time ( ) if self . _run_sync or is_affirmative ( os . environ . get ( 'DBM_THREADED_JOB_RUN_SYNC' , "false" ) ) : self . _log . debug ( "Running threaded job synchronously. job=%s" , self . _job_name ) self . _run_job_rate_limited ( ) elif self . _job_loop_future is None or not self . _job_loop_future . running ( ) : self . _job_loop_future = DBMAsyncJob . executor . submit ( self . _job_loop ) else : self . _log . debug ( "Job loop already running. job=%s" , self . _job_name )