Skip to content

Commit

Permalink
Fix typos
Browse files Browse the repository at this point in the history
  • Loading branch information
svallero committed Jan 11, 2024
1 parent 1cb4cf5 commit d35ea10
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions kubernetes_airflow_dag_2.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,17 +28,17 @@
from airflow.example_dags.libs.helper import print_stuff
from airflow.models.dag import DAG

[docs]log = logging.getLogger(__name__)
log = logging.getLogger(__name__)

[docs]worker_container_repository = conf.get("kubernetes_executor", "worker_container_repository")
[docs]worker_container_tag = conf.get("kubernetes_executor", "worker_container_tag")
worker_container_repository = conf.get("kubernetes_executor", "worker_container_repository")
worker_container_tag = conf.get("kubernetes_executor", "worker_container_tag")

try:
from kubernetes.client import models as k8s
except ImportError:
log.warning("Could not import DAGs in example_local_kubernetes_executor.py", exc_info=True)
log.warning("Install Kubernetes dependencies with: pip install apache-airflow[cncf.kubernetes]")
[docs] k8s = None
k8s = None

if k8s:
with DAG(
Expand All @@ -49,7 +49,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"}))
}

Expand Down

0 comments on commit d35ea10

Please sign in to comment.