Commit 0d2daffd authored by 김진영's avatar 김진영
Browse files

Update batch_test.py

parent fe5097ee
...@@ -5,6 +5,7 @@ from airflow.operators.bash import BashOperator ...@@ -5,6 +5,7 @@ from airflow.operators.bash import BashOperator
from airflow import DAG from airflow import DAG
from data.gasan_data import gasanData # import cj-gasan data from data.gasan_data import gasanData # import cj-gasan data
from dateutil.relativedelta import relativedelta from dateutil.relativedelta import relativedelta
from airflow.models import Variable
# set timezone # set timezone
local_tz = pendulum.timezone("Asia/Seoul") local_tz = pendulum.timezone("Asia/Seoul")
...@@ -60,7 +61,7 @@ with DAG( ...@@ -60,7 +61,7 @@ with DAG(
# (Task1) 헬스체크 # (Task1) 헬스체크
health_check = BashOperator( health_check = BashOperator(
task_id='health_check', task_id='health_check',
bash_command="curl -X GET -v http://10.231.238.224:30999/api/v1/core/health \'-H accept: application/json\'", bash_command="curl -X GET -v {api_url}/api/v1/core/health \'-H accept: application/json\'".format(Variable.get("INF_API_URL ")),
) )
# (Task2) gasan 작업 병렬처리 # (Task2) gasan 작업 병렬처리
......
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