diff --git a/airflow/HomePlus_dag.py b/airflow/HomePlus_dag.py index 82d9d6a..1c7cab7 100644 --- a/airflow/HomePlus_dag.py +++ b/airflow/HomePlus_dag.py @@ -76,4 +76,4 @@ def generate_queue_values(): ] >> collect_task_results_task >> send_summary_email # Task 결과 수집 후 이메일 전송 -##### \ No newline at end of file +##### ## \ No newline at end of file diff --git a/messagequeue/consumer/HomePlus_consumer.py b/messagequeue/consumer/HomePlus_consumer.py index 1d733c4..e43adfd 100644 --- a/messagequeue/consumer/HomePlus_consumer.py +++ b/messagequeue/consumer/HomePlus_consumer.py @@ -110,4 +110,4 @@ def callback(ch, method, properties, body): reset_timer() # 타이머 초기화 channel.start_consuming() # 메시지 수신 시작 -##### \ No newline at end of file +##### ## \ No newline at end of file