https://github.com/apache/airflow/blob/main/airflow/dag_processing/manager.py#L773
#
#
#
"""Processes DAGs."""
from __future__ import annotations
import collections
import enum
import importlib
import inspect
import logging
import multiprocessing
import os
import random
import signal
import sys
import time
import zipfile
from collections import defaultdict
from datetime import datetime, timedelta
from importlib import import_module
from multiprocessing.connection import Connection as MultiprocessingConnection
from pathlib import Path
from typing import Any, NamedTuple, cast