def __init__(self,<EOL>dag_directory,<EOL>file_paths,<EOL>max_runs,<EOL>processor_factory,<EOL>signal_conn,<EOL>stat_queue,<EOL>result_queue,<EOL>async_mode=True):
self._file_paths = file_paths<EOL>self._file_path_queue = []<EOL>self._dag_directory = dag_directory<EOL>self._max_runs = max_runs<EOL>self._processor_factory = processor_factory<EOL>self._signal_conn = signal_conn<EOL>self._stat_queue = stat_queue<EOL>self._result_queue = result_queue<EOL>self._async_mode = async_mode<EOL>self._parallelism = conf.getint('<STR_LIT>', '<STR_LIT>')<EOL>if '<STR_LIT>' in conf.get('<STR_LIT>', '<STR_LIT>') and self._parallelism > <NUM_LIT:1>:<EOL><INDENT>self.log.error("<STR_LIT>"<EOL>"<STR_LIT>")<EOL>self._parallelism = <NUM_LIT:1><EOL><DEDENT>self._file_process_interval = conf.getint('<STR_LIT>',<EOL>'<STR_LIT>')<EOL>self.print_stats_interval = conf.getint('<STR_LIT>',<EOL>'<STR_LIT>')<EOL>self._zombie_threshold_secs = (<EOL>conf.getint('<STR_LIT>', '<STR_LIT>'))<EOL>self._processors = {}<EOL>self._last_runtime = {}<EOL>self._last_finish_time = {}<EOL>self._last_zombie_query_time = timezone.utcnow()<EOL>self.last_dag_dir_refresh_time = timezone.utcnow()<EOL>self.last_stat_print_time = timezone.datetime(<NUM_LIT>, <NUM_LIT:1>, <NUM_LIT:1>)<EOL>self._zombie_query_interval = <NUM_LIT:10><EOL>self._run_count = defaultdict(int)<EOL>self._heart_beat_key = '<STR_LIT>'<EOL>self.dag_dir_list_interval = conf.getint('<STR_LIT>',<EOL>'<STR_LIT>')<EOL>self._log = logging.getLogger('<STR_LIT>')<EOL>signal.signal(signal.SIGINT, self._exit_gracefully)<EOL>signal.signal(signal.SIGTERM, self._exit_gracefully)<EOL>
:param dag_directory: Directory where DAG definitions are kept. All
    files in file_paths should be under this directory
:type dag_directory: unicode
:param file_paths: list of file paths that contain DAG definitions
:type file_paths: list[unicode]
:param max_runs: The number of times to parse and schedule each file. -1
    for unlimited.
:type max_runs: int
:param processor_factory: function that creates processors for DAG
    definition files. Arguments are (dag_definition_path)
:type processor_factory: (unicode, unicode, list) -> (AbstractDagFileProcessor)
:param signal_conn: connection to communicate signal with processor agent.
:type signal_conn: airflow.models.connection.Connection
:param stat_queue: the queue to use for passing back parsing stat to agent.
:type stat_queue: multiprocessing.Queue
:param result_queue: the queue to use for passing back the result to agent.
:type result_queue: multiprocessing.Queue
:param async_mode: whether to start the manager in async mode
:type async_mode: bool