diff --git a/dags/ods/kktix_ticket_orders/udfs/kktix_api.py b/dags/ods/kktix_ticket_orders/udfs/kktix_api.py index 62a642f..2e66dad 100644 --- a/dags/ods/kktix_ticket_orders/udfs/kktix_api.py +++ b/dags/ods/kktix_ticket_orders/udfs/kktix_api.py @@ -28,9 +28,6 @@ def main(**context): year = ts_datetime_obj.year timestamp = ts_datetime_obj.timestamp() event_raw_data_array = _extract(year=year, timestamp=timestamp,) - # load name and email to mailer before data has been hashed - # wait for other services - # klaviyo_loader.load(event_raw_data_array) transformed_event_raw_data_array = kktix_transformer.transform( copy.deepcopy(event_raw_data_array) )