AWS CLI DAG using CWL

unity-sds · Feb 27, 2024 · a458a31 · a458a31
1 parent 13dea6b
commit a458a31
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/airflow/dags/aws_cli_cwl_dag.py b/airflow/dags/aws_cli_cwl_dag.py
@@ -1,6 +1,7 @@
 import uuid
 from datetime import datetime
 
+from airflow.models.param import Param
 from airflow.providers.cncf.kubernetes.operators.kubernetes_pod import KubernetesPodOperator
 from kubernetes.client import models as k8s
 
@@ -31,6 +32,7 @@
     schedule=None,
     max_active_runs=1,
     default_args=dag_default_args,
+    params={"cwl_workflow": Param(CWL_WORKFLOW, type="string")},
 )
 
 # Task that executes the specific CWL workflow with the previous arguments