Skip to content

Commit

Permalink
fix(ods): remove unused gathertown task
Browse files Browse the repository at this point in the history
  • Loading branch information
Henry Lee committed Jun 23, 2024
1 parent 6e2ae23 commit eb398c3
Showing 1 changed file with 3 additions and 9 deletions.
12 changes: 3 additions & 9 deletions dags/ods/kktix_ticket_orders/kktix_dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from ods.kktix_ticket_orders.udfs import bigquery_loader, gather_town_loader, kktix_api
from ods.kktix_ticket_orders.udfs import bigquery_loader, kktix_api

DEFAULT_ARGS = {
"owner": "[email protected]",
Expand All @@ -16,7 +16,7 @@
"on_failure_callback": lambda x: "Need to send notification to Discord!",
}
dag = DAG(
"KKTIX_TICKET_ORDERS_V7",
"KKTIX_TICKET_ORDERS_V8",
default_args=DEFAULT_ARGS,
schedule_interval="50 * * * *",
max_active_runs=1,
Expand All @@ -34,13 +34,7 @@
provide_context=True,
)

ADD_USER_TO_GATHER_TOWN_WHITELIST = PythonOperator(
task_id="ADD_USER_TO_GATHER_TOWN_WHITELIST",
python_callable=gather_town_loader.load,
provide_context=True,
)

CREATE_TABLE_IF_NEEDED >> GET_ATTENDEE_INFOS >> ADD_USER_TO_GATHER_TOWN_WHITELIST
CREATE_TABLE_IF_NEEDED >> GET_ATTENDEE_INFOS

if __name__ == "__main__":
dag.cli()

0 comments on commit eb398c3

Please sign in to comment.