https://github.com/apache/airflow/blob/main/airflow/cli/commands/task_command.py#L145
#
#
#
from __future__ import annotations
import collections.abc
import contextlib
import hashlib
import itertools
import logging
import math
import operator
import os
import signal
import warnings
from collections import defaultdict
from datetime import timedelta
from enum import Enum