diff --git a/airflow/HomePlus_dag.py b/airflow/HomePlus_dag.py index b5acb41..027edf3 100644 --- a/airflow/HomePlus_dag.py +++ b/airflow/HomePlus_dag.py @@ -73,4 +73,7 @@ def generate_queue_values(): [ run_consumer_task, # Consumer send_post_request_HOMEPLUS_task.expand(category_id=category_ids), # Producer - ] >> collect_task_results_task >> send_summary_email # Task 결과 수집 후 이메일 전송 \ No newline at end of file + ] >> collect_task_results_task >> send_summary_email # Task 결과 수집 후 이메일 전송 + + + ### \ No newline at end of file diff --git a/airflow/requirements.txt b/airflow/requirements.txt index 4d241e0..b800f12 100644 --- a/airflow/requirements.txt +++ b/airflow/requirements.txt @@ -136,7 +136,6 @@ swagger-ui-bundle==0.0.9 tabulate==0.9.0 tenacity==8.1.0 termcolor==2.0.1 -text-unidecode==1.3 typing_extensions==4.12.2 tzdata==2024.1 uc-micro-py==1.0.1 diff --git a/messagequeue/consumer/HomePlus_consumer.py b/messagequeue/consumer/HomePlus_consumer.py index e178e02..ccd67bb 100644 --- a/messagequeue/consumer/HomePlus_consumer.py +++ b/messagequeue/consumer/HomePlus_consumer.py @@ -110,3 +110,4 @@ def callback(ch, method, properties, body): reset_timer() # 타이머 초기화 channel.start_consuming() # 메시지 수신 시작 +### \ No newline at end of file diff --git a/messagequeue/producer/HomePlus/requirements.txt b/messagequeue/producer/HomePlus/requirements.txt index 228ecfd..6b93c23 100644 --- a/messagequeue/producer/HomePlus/requirements.txt +++ b/messagequeue/producer/HomePlus/requirements.txt @@ -2,4 +2,4 @@ pika==1.3.2 Flask>=2.0.0 Werkzeug>=2.0.0 requests==2.32.3 -python-dotenv \ No newline at end of file +python-dotenv==1.0.1 \ No newline at end of file