Skip to content

Commit

Permalink
Create dags_airflow_fede_rucio_k8soperator.py
Browse files Browse the repository at this point in the history
  • Loading branch information
leggerf authored Jan 31, 2024
1 parent d3c994e commit 63ff325
Showing 1 changed file with 23 additions and 0 deletions.
23 changes: 23 additions & 0 deletions dags_airflow_fede_rucio_k8soperator.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator
from airflow import DAG
from datetime import datetime

default_args = {
'owner': 'airflow',
'start_date': datetime(2020, 1, 1),
}

dag = DAG('kubernetes_sample', default_args=default_args, schedule_interval=None)

k = KubernetesPodOperator(
namespace='airflow',
image="ubuntu:16.04",
cmds=["bash", "-cx"],
arguments=["echo", "10"],
labels={"foo": "bar"},
name="airflow-test-pod",
task_id="task",
is_delete_operator_pod=True,
hostnetwork=False,
dag=dag
)

0 comments on commit 63ff325

Please sign in to comment.