Skip to content

Commit

Permalink
Update dags_airflow_fede_k8sexecutor.py
Browse files Browse the repository at this point in the history
  • Loading branch information
leggerf authored Jan 26, 2024
1 parent 0a3344b commit 4045f3b
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions dags_airflow_fede_k8sexecutor.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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:
Expand All @@ -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"}))
}

Expand Down

0 comments on commit 4045f3b

Please sign in to comment.