Skip to content

Commit

Permalink
changing DAG schedule_interval
Browse files Browse the repository at this point in the history
  • Loading branch information
HyejiYu committed Sep 25, 2024
1 parent d964627 commit 807f104
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions airflow/dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,8 @@ def send_post_request(categoryId):
'HomePlus_Crawling_DAG', # DAG의 이름
default_args=default_args, # 기본 인자 설정
description='HomePlus Crawling', # DAG 설명
schedule_interval='0 9,16,22 * * *', # 실행 주기 (매일 09:00, 16:00, 22:00 정각)
#schedule_interval='0 9,16,22 * * *', # 실행 주기 (매일 09:00, 16:00, 22:00 정각)
schedule_interval='0 * * * *',
start_date=datetime(2024, 9, 20), # 시작 날짜
catchup=False # 시작 날짜부터 현재까지의 미실행 작업 실행 여부
) as dag:
Expand Down Expand Up @@ -87,4 +88,4 @@ def generate_queue_values():

category_ids = list(range(100001, 100078))

[run_consumer_task, send_post_request_HOMEPLUS_task.expand(category_id=category_ids)]
[run_consumer_task, send_post_request_HOMEPLUS_task.expand(category_id=category_ids)]

0 comments on commit 807f104

Please sign in to comment.