Add register task.

digital-land · Jul 23, 2024 · 665ae75 · 665ae75
1 parent d1d9b55
commit 665ae75
Showing 1 changed file with 9 additions and 10 deletions.
diff --git a/dags/dynamic_data_workflow_dag.py b/dags/dynamic_data_workflow_dag.py
@@ -10,17 +10,17 @@
 )
 
 cluster_name = "development-cluster"
-"""
-register_task = EcsRegisterTaskDefinitionOperator(
-    task_id="register-task",
-    family="test",
+
+collection_task = EcsRegisterTaskDefinitionOperator(
+    task_id="collection-task",
+    family="collection",
     container_definitions=[
         {
-            "name": "hello",
-            "image": "ubuntu",
-            "workingDirectory": "/usr/bin",
-            "entryPoint": ["sh", "-c"],
-            "command": ["ls"],
+            "name": "collection-task",
+            "image": "collection-task",
+            #"workingDirectory": "/usr/bin",
+            #"entryPoint": ["sh", "-c"],
+            #"command": ["ls"],
             # "logConfiguration": {
             #     "logDriver": "awslogs",
             #     "options": {
@@ -38,7 +38,6 @@
         "requiresCompatibilities": ["FARGATE"],
     },
 )
-"""
 
 my_dir = os.path.dirname(os.path.abspath(__file__))
 configuration_file_path = os.path.join(my_dir, "config.json")