Merge pull request #142 from pycontw/bugfix/2024-ticket

Bugfix/2024 ticket
pycontw · Jun 29, 2024 · 95dcdf7 · 95dcdf7
2 parents 74422a9 + a7a4289
commit 95dcdf7
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/dags/ods/kktix_ticket_orders/kktix_dag.py b/dags/ods/kktix_ticket_orders/kktix_dag.py
@@ -10,13 +10,13 @@
 DEFAULT_ARGS = {
     "owner": "[email protected]",
     "depends_on_past": False,
-    "start_date": datetime(2024, 6, 18, 0),
+    "start_date": datetime(2024, 6, 16, 15),  # 23 (+8)
     "retries": 2,
     "retry_delay": timedelta(minutes=5),
     "on_failure_callback": lambda x: "Need to send notification to Discord!",
 }
 dag = DAG(
-    "KKTIX_TICKET_ORDERS_V8",
+    "KKTIX_TICKET_ORDERS_V10",
     default_args=DEFAULT_ARGS,
     schedule_interval="50 * * * *",
     max_active_runs=1,

diff --git a/dags/ods/kktix_ticket_orders/udfs/kktix_api.py b/dags/ods/kktix_ticket_orders/udfs/kktix_api.py
@@ -121,6 +121,9 @@ def _get_attendee_infos(
     """
     get attendee infos, e.g. email, phonenumber, name and etc
     """
+    print(
+        f"Fetching attendee infos between {timestamp} and {timestamp + SCHEDULE_INTERVAL_SECONDS}"
+    )
     attendee_infos = []
     for attendee_id in attendee_ids:
         attendee_info = HTTP_HOOK.run_with_advanced_retry(