https://github.com/apache/airflow/blob/main/airflow/cli/commands/task_command.py#L145
#
#
#
from __future__ import annotations
import collections.abc
import contextlib
import copy
import datetime
import itertools
import json
import logging
import math
import operator
import os
import sys
import traceback
import warnings
from bisect import insort_left
from collections import defaultdict
from functools import cached_property, wraps
from json import JSONDecodeError