Update batch_test.py

batch_test.py

@@ -21,56 +21,16 @@ with DAG(
     tags=['test'],
     catchup=False,
 ) as dag:
-    # post_gasan_tasks = []
+    # gasan 작업 병렬처리
+    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)
-    # 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\"}\'",
-    )
+        post_gasan_tasks.append(post_gasan_task)
 
-    # t2 = BashOperator(
-    #     task_id='sleep',
-    #     depends_on_past=False,
-    #     bash_command='sleep 5',
-    #     retries=3,
-    # )
-    # t1.doc_md = dedent(
-    #     """\
-    # #### Task Documentation
-    # You can document your task using the attributes `doc_md` (markdown),
-    # `doc` (plain text), `doc_rst`, `doc_json`, `doc_yaml` which gets
-    # rendered in the UI's Task Instance Details page.
-    # ![img](http://montcs.bloomu.edu/~bobmon/Semesters/2012-01/491/import%20soul.png)
-
-    # """
-    # )
-
-    # dag.doc_md = __doc__  # providing that you have a docstring at the beginning of the DAG
-    # dag.doc_md = """
-    # This is a documentation placed anywhere
-    # """  # otherwise, type it like this
-    # templated_command = dedent(
-    #     """
-    # {% for i in range(5) %}
-    #     echo "{{ ds }}"
-    #     echo "{{ macros.ds_add(ds, 7)}}"
-    # {% endfor %}
-    # """
-    # )
-
-    # t3 = BashOperator(
-    #     task_id='templated',
-    #     depends_on_past=False,
-    #     bash_command=templated_command,
-    # )
-
-    # post_gasan_tasks
-    t1
+    post_gasan_tasks
+    # t1