self.processor_agent = DagFileProcessorAgent(
            dag_directory=tmp_path,
            max_runs=1,
            processor_timeout=datetime.timedelta(1),
            dag_ids=[],
            pickle_dags=False,
            async_mode=False,
        )
        self.processor_agent.start()
        self.processor_agent.run_single_parsing_loop()
        self.processor_agent.wait_until_finished()
    @conf_vars({("core", "mp_start_method"): "spawn"})
    def test_spawn_multiprocessing_behaviour(self, tmp_path):
        self.processor_agent = DagFileProcessorAgent(
            dag_directory=tmp_path,
            max_runs=1,
            processor_timeout=datetime.timedelta(1),
            dag_ids=[],
            pickle_dags=False,
            async_mode=False,
        )
        self.processor_agent.start()
        self.processor_agent.run_single_parsing_loop()
        self.processor_agent.wait_until_finished()