def __init__()

in pygenie/jobs/running.py [0:0]

• 15 lines of code
• 6 McCabe index (conditional complexity)

    def __init__(self, job_id, adapter=None, conf=None, info=None):
        global get_adapter_for_version  # See comment at pygenie/__init__.py:38
        self._cached_genie_log = None
        self._cached_stderr = None
        self._conf = conf or GenieConf()
        self._info = info or dict()
        self._job_id = job_id
        self._status = self._info.get('status') or None
        self._sys_stream = None

        # get_adapter_version is set in main __init__.py to get around circular imports
        self._adapter = adapter \
            or get_adapter_for_version(self._conf.genie.version)(conf=self._conf)

        stream = self._conf.get('genie.progress_stream', 'stdout').lower()
        if stream in {'stderr', 'stdout'}:
            self._sys_stream = getattr(sys, stream)

        self.__reload_stderr = True