Update batch_test.py

batch_test.py

@@ -17,20 +17,20 @@ with DAG(
     start_date=datetime(2022, 5, 13),
     tags=['test'],
 ) as dag:
-    post_gasan_tasks = []
+    # post_gasan_tasks = []
 
-    for i in range(4):
-        post_gasan_task = BashOperator(
-            task_id='post_gasan'+str(i),
-            bash_command="curl -X \'POST\' \'http://10.231.238.224:30999/api/v1/camera/writeimage\' -H \'Content-Type: application/json\' -d \'{\"id\": \"test%s\", \"pw\": \"test\", \"ip\": \"10.123.123.1\", \"serialNum\": \"aaaa\", \"camName\": \"abc\"}\'" %(str(i)),
-        )
+    # for i in range(4):
+    #     post_gasan_task = BashOperator(
+    #         task_id='post_gasan'+str(i),
+    #         bash_command="curl -X \'POST\' \'http://10.231.238.224:30999/api/v1/camera/writeimage\' -H \'Content-Type: application/json\' -d \'{\"id\": \"test%s\", \"pw\": \"test\", \"ip\": \"10.123.123.1\", \"serialNum\": \"aaaa\", \"camName\": \"abc\"}\'" %(str(i)),
+    #     )
 
-        post_gasan_tasks.append(post_gasan_task)
+    #     post_gasan_tasks.append(post_gasan_task)
     # t1, t2 and t3 are examples of tasks created by instantiating operators
-    # t1 = BashOperator(
-    #     task_id='post_gasan',
-    #     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\": \"10.123.123.1\", \"serialNum\": \"aaaa\", \"camName\": \"abc\"}\'",
-    # )
+    t1 = BashOperator(
+        task_id='post_gasan',
+        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\": \"10.123.123.1\", \"serialNum\": \"aaaa\", \"camName\": \"abc\"}\'",
+    )
 
     # t2 = BashOperator(
     #     task_id='sleep',
@@ -68,4 +68,5 @@ with DAG(
     #     bash_command=templated_command,
     # )
 
-    post_gasan_tasks
+    # post_gasan_tasks
+    t1