From 571b428b9fc52dc4a722ec4ea138dd03600760f0 Mon Sep 17 00:00:00 2001 From: Victor Ng Date: Tue, 6 Mar 2018 13:16:35 -0500 Subject: [PATCH] Parse the date string into a proper date object in taar_dynamo. --- mozetl/taar/taar_dynamo.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/mozetl/taar/taar_dynamo.py b/mozetl/taar/taar_dynamo.py index 09634418..ab9dcfdb 100644 --- a/mozetl/taar/taar_dynamo.py +++ b/mozetl/taar/taar_dynamo.py @@ -408,8 +408,9 @@ def main(date, region, table, prod_iam_role, sample_rate): APP_NAME = "HBaseAddonRecommenderView" conf = SparkConf().setAppName(APP_NAME) spark = SparkSession.builder.config(conf=conf).getOrCreate() + date_obj = datetime.strptime(date, "%Y%m%d") reduction_output = run_etljob(spark, - date, + date_obj, region, table, prod_iam_role,