diff --git a/dags_airflow_fede_k8sexecutor.py b/dags_airflow_fede_k8sexecutor.py index 98baf4d..be4c5ac 100644 --- a/dags_airflow_fede_k8sexecutor.py +++ b/dags_airflow_fede_k8sexecutor.py @@ -13,7 +13,7 @@ from airflow.example_dags.libs.helper import print_stuff from airflow.models.dag import DAG -[docs]log = logging.getLogger(__name__) +log = logging.getLogger(__name__) try: from kubernetes.client import models as k8s @@ -22,7 +22,7 @@ "The example_kubernetes_executor example DAG requires the kubernetes provider." " Please install it with: pip install apache-airflow[cncf.kubernetes]" ) -[docs] k8s = None + k8s = None if k8s: @@ -34,7 +34,7 @@ tags=["example3"], ) as dag: # You can use annotations on your kubernetes pods! -[docs] start_task_executor_config = { + start_task_executor_config = { "pod_override": k8s.V1Pod(metadata=k8s.V1ObjectMeta(annotations={"test": "annotation"})) }