#
#
#
from __future__ import annotations
import abc
import enum
import logging
import re
import sys
from io import IOBase
from logging import Handler, Logger, StreamHandler
from typing import IO, cast
from airflow.settings import IS_K8S_EXECUTOR_POD
ANSI_ESCAPE = re.compile(r"\x1B[@-_][0-?]*[ -/]*[@-~]")
class SetContextPropagate(enum.Enum):