def METHOD_NAME(self):
    """
    We can properly pick up Airflow's payload and convert
    it to our models
    """
    serialized_dag = {
        "__version": 1,
        "dag": {
            "_dag_id": "test-lineage-253",
            "fileloc": "/opt/airflow/dags/lineage-test.py",
            "default_args": {
                "__var": {
                    "owner": "airflow",
                    "depends_on_past": False,
                    "email": ["airflow@example.com"],
                    "email_on_failure": False,
                    "email_on_retry": False,
                    "retries": 1,
                    "retry_delay": {"__var": 1, "__type": "timedelta"},
                },
                "__type": "dict",
            },
            "timezone": "UTC",
            "catchup": False,
            "edge_info": {},
            "dataset_triggers": [],
            "_description": "An example DAG which simulate dbt run of fct_application_summary for airflow lineage backend",
            "_task_group": {
                "_group_id": None,
                "prefix_group_id": True,
                "tooltip": "",
                "ui_color": "CornflowerBlue",
                "ui_fgcolor": "#000",
                "children": {
                    "task0": ["operator", "task0"],
                    "task1": ["operator", "task1"],
                },
                "upstream_group_ids": [],
                "downstream_group_ids": [],
                "upstream_task_ids": [],
                "downstream_task_ids": [],
            },
            "is_paused_upon_creation": False,
            "start_date": 1688860800,
            "schedule_interval": None,
            "_processor_dags_folder": "/opt/airflow/dags",
            "tasks": [
                {
                    "owner": "airflow",
                    "retry_delay": 1,
                    "retries": 1,
                    "ui_color": "#e8f7e4",
                    "email": ["airflow@example.com"],
                    "task_id": "task0",
                    "email_on_failure": False,
                    "email_on_retry": False,
                    "pool": "default_pool",
                    "downstream_task_ids": ["task1"],
                    "template_ext": [],
                    "template_fields_renderers": {},
                    "inlets": [
                        {
                            "__var": {
                                "tables": [
                                    "sample_data.ecommerce_db.shopify.dim_location"
                                ]
                            },
                            "__type": "dict",
                        }
                    ],
                    "template_fields": [],
                    "ui_fgcolor": "#000",
                    "_task_type": "EmptyOperator",
                    "_task_module": "airflow.operators.empty",
                    "_is_empty": True,
                },
                {
                    "outlets": [
                        {
                            "__var": {
                                "tables": [
                                    "sample_data.ecommerce_db.shopify.dim_staff"
                                ]
                            },
                            "__type": "dict",
                        }
                    ],
                    "owner": "airflow",
                    "retry_delay": 1,
                    "retries": 1,
                    "ui_color": "#e8f7e4",
                    "email": ["airflow@example.com"],
                    "task_id": "task1",
                    "email_on_failure": False,
                    "email_on_retry": False,
                    "pool": "default_pool",
                    "downstream_task_ids": [],
                    "template_ext": [],
                    "template_fields_renderers": {},
                    "template_fields": [],
                    "ui_fgcolor": "#000",
                    "_task_type": "EmptyOperator",
                    "_task_module": "airflow.operators.empty",
                    "_is_empty": True,
                },
            ],
            "dag_dependencies": [],
            "params": {},
        },
    }
    data = serialized_dag["dag"]
    dag = AirflowDagDetails(
        dag_id="id",
        fileloc="loc",
        data=AirflowDag.parse_obj(serialized_dag),
        max_active_runs=data.get("max_active_runs", None),
        description=data.get("_description", None),
        start_date=data.get("start_date", None),
        tasks=data.get("tasks", []),
        schedule_interval=None,
        owners=None,
    )
    self.assertEquals(
        dag.tasks[0].inlets,
        [
            {
                "__var": {
                    "tables": ["sample_data.ecommerce_db.shopify.dim_location"]
                },
                "__type": "dict",
            }
        ],
    )
    self.assertEquals(
        dag.tasks[1].outlets,
        [
            {
                "__var": {"tables": ["sample_data.ecommerce_db.shopify.dim_staff"]},
                "__type": "dict",
            }
        ],
    )