def get_or_create_logger(self, job_id: bytes):
    job_id = job_id.decode()
    if (job_id not in self._per_job_logger_cache):
        params = self._logging_params.copy()
        params['filename'] = f'runtime_env_setup-{job_id}.log'
        params['logger_name'] = f'runtime_env_{job_id}'
        per_job_logger = setup_component_logger(**params)
        self._per_job_logger_cache[job_id] = per_job_logger
    return self._per_job_logger_cache[job_id]
def get_or_create_logger(self, job_id: bytes):
    job_id = job_id.decode()
    if (job_id not in self._per_job_logger_cache):
        params = self._logging_params.copy()
        params['filename'] = f'runtime_env_setup-{job_id}.log'
        params['logger_name'] = f'runtime_env_{job_id}'
        per_job_logger = setup_component_logger(**params)
        self._per_job_logger_cache[job_id] = per_job_logger
    return self._per_job_logger_cache[job_id]