[Airflow][ISSUE] KubernetesPodOperator Resource error
▪ Synopsis Airflow을 Kubernetes 기반으로 세팅 후 Dag Task들을 KubernetesPodOperator로 사용하고 있다. code refactoring 과정에서 resource 부분을 MIN, MID, MAX로 분류 후 사용하기 위해 enum 변수를 정의해서 적용했다. def get_k8s_operator( task_id, image, dag, cmds=None, arguments=None, secrets=None, volumes=None, volume_mounts=None, resources=min_resources, ): return KubernetesPodOperator( name=task_id.replace("_", "-"), task_id=task_id, image=..
