This method is used in DagFileProcessor.process_file - it may be easier to migrate all it's internal calls instead of the whole method.
{
                    "test_subdag_operator": "dags/test_subdag.py",
                    "test_subdag_operator.section-1": "dags/test_subdag.py",
                },
                id="test_subdag_operator",
            ),
        ),
    )
    def test_get_dag_registration(self, file_to_load, expected):
        dagbag = models.DagBag(dag_folder=os.devnull, include_examples=False)
        dagbag.process_file(str(file_to_load))
        for dag_id, path in expected.items():
            dag = dagbag.get_dag(dag_id)
            assert dag, f"{dag_id} was bagged"
            assert dag.fileloc.endswith(path)
    def test_dag_registration_with_failure(self):
        dagbag = models.DagBag(dag_folder=os.devnull, include_examples=False)
        found = dagbag.process_file(str(TEST_DAGS_FOLDER / "test_invalid_dup_task.py"))
        assert [] == found
    @pytest.fixture()
    def zip_with_valid_dag_and_dup_tasks(self, tmp_path: pathlib.Path) -> Iterator[str]:
        failing_dag_file = TEST_DAGS_FOLDER / "test_invalid_dup_task.py"
        working_dag_file = TEST_DAGS_FOLDER / "test_example_bash_operator.py"
        zipped = os.path.join(tmp_path, "test_zip_invalid_dup_task.zip")
        with zipfile.ZipFile(zipped, "w") as zf:
            zf.write(failing_dag_file, os.path.basename(failing_dag_file))
            zf.write(working_dag_file, os.path.basename(working_dag_file))
        yield zipped
        os.unlink(zipped)
    def test_dag_registration_with_failure_zipped(self, zip_with_valid_dag_and_dup_tasks):