Commit e492a9a2 authored by 김진영's avatar 김진영
Browse files

Update batch_test.py

parent 81dd05e5
......@@ -3,35 +3,11 @@ from textwrap import dedent
import pendulum
from airflow.operators.bash import BashOperator
from airflow import DAG
from data.gasan_data import gasanData
from data.gasan_data import gasanData # import cj-gasan data
# set timezone
local_tz = pendulum.timezone("Asia/Seoul")
print(gasanData)
# gasan 데이터 선언
# gasan_data = [
# {
# "ip": "10.231.130.110",
# "serialNum": "7D0B3C9PAGFCF3C",
# "camName": "dt_lab_1"
# },
# {
# "ip": "10.231.130.111",
# "serialNum": "7D0B3C9PAG8D150",
# "camName": "dt_lab_2"
# },
# {
# "ip": "10.231.130.112",
# "serialNum": "7D0B3C9PAGBB838",
# "camName": "dt_lab_3"
# },
# {
# "ip": "10.231.130.113",
# "serialNum": "7D0B3C9PAG17F50",
# "camName": "dt_lab_4"
# },
# ]
with DAG(
'batch_test',
default_args={
......@@ -55,4 +31,5 @@ with DAG(
post_gasan_tasks.append(post_gasan_task)
# 작업 순서 정의
post_gasan_tasks
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment