add col

alexdemeo · alexdemeo · commit b80d030dfbfd · 2024-03-28T17:54:04.000-07:00
diff --git a/pyspark/script.py b/pyspark/script.py
@@ -19,6 +19,7 @@ def run_job(spark, final_output_table):
       b.earning_adjustment_commission_rate AS "commission_rate",
       b.receipt_payment_type AS "payment_type",
       b.reward_id AS "reward_id",
+      b.date_id as "date_id",
       c.*,
     FROM
       bookings_30_days b
