#
#
from __future__ import annotations
import base64
import pickle
from unittest import mock
import pytest
from airflow.decorators import task
from airflow.utils import timezone
DEFAULT_DATE = timezone.datetime(2021, 9, 1)
KPO_MODULE = "airflow.providers.cncf.kubernetes.operators.pod"
POD_MANAGER_CLASS = "airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager"
HOOK_CLASS = "airflow.providers.cncf.kubernetes.operators.pod.KubernetesHook"
XCOM_IMAGE = "XCOM_IMAGE"
@pytest.fixture(autouse=True)
def mock_create_pod() -> mock.Mock: