#
#
#
from __future__ import annotations
import datetime
from functools import reduce
from typing import Mapping
from unittest import mock
from unittest.mock import call
import pendulum
import pytest
from sqlalchemy.orm.session import Session
from airflow import settings
from airflow.callbacks.callback_requests import DagCallbackRequest
from airflow.decorators import setup, task, task_group, teardown
from airflow.models import (
    DAG,
    DagBag,
    DagModel,
    DagRun,
    TaskInstance,
    TaskInstance as TI,
    clear_task_instances,