Update batch_test.py

batch_test.py

@@ -17,16 +17,24 @@ with DAG(
         'retry_delay': timedelta(minutes=5),
     },
     description='Test Batch Job',
-    schedule_interval='* * * * *',
+    schedule_interval='*/1 * * * *',
     start_date=datetime(2022, 5, 13),
     tags=['test'],
 ) as dag:
+    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\", \"pw\": \"test\", \"ip\": \"10.123.123.1\", \"serialNum\": \"aaaa\", \"camName\": \"abc\"}\'",
+        )
+
+        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',
@@ -64,4 +72,4 @@ with DAG(
     #     bash_command=templated_command,
     # )
 
-    t1
+    post_gasan_tasks