Update batch_test.py

batch_test.py

@@ -27,16 +27,15 @@ with DAG(
     )
 
     # (Task2) gasan 작업 병렬처리
-    # post_gasan_tasks = []
+    post_gasan_tasks = []
 
-    # for i, data in enumerate(gasanData):
-    #     post_gasan_task = BashOperator(
-    #         task_id='post_gasan'+str(i+1),
-    #         bash_command="curl -X \'POST\' \'http://10.231.238.224:30999/api/v1/camera/writeimage\' -H \'Content-Type: application/json\' -d \'{\"id\": \"test\", \"pw\": \"test\", \"ip\": \"%s\", \"serialNum\": \"%s\", \"camName\": \"%s\"}\'" %(data["ip"], data["serialNum"], data["camName"]),
-    #     )
+    for i, data in enumerate(gasanData):
+        post_gasan_task = BashOperator(
+            task_id='post_gasan'+str(i+1),
+            bash_command="curl -X \'POST\' \'http://10.231.238.224:30999/api/v1/camera/writeimage\' -H \'Content-Type: application/json\' -d \'{\"id\": \"test\", \"pw\": \"test\", \"ip\": \"%s\", \"serialNum\": \"%s\", \"camName\": \"%s\"}\'" %(data["ip"], data["serialNum"], data["camName"]),
+        )
 
-    #     post_gasan_tasks.append(post_gasan_task)
+        post_gasan_tasks.append(post_gasan_task)
 
     # 작업 순서 정의
-    # post_gasan_tasks
-    health_check
+    health_check >> post_gasan_tasks