X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=csit.infra.etl%2Fcoverage_device_rls2210.py;fp=csit.infra.etl%2Fcoverage_device_rls2210.py;h=0822d13a9ae2a72defdd11dbe27378d03d1bbfa2;hb=5f4aeffb078342604a3fb1be86d91e7a12750691;hp=9c9e1c96031db6ca2b605b68f1360abcdabffe85;hpb=420226fcfd8cab460f632c1401d6012dc353f6fd;p=csit.git diff --git a/csit.infra.etl/coverage_device_rls2210.py b/csit.infra.etl/coverage_device_rls2210.py index 9c9e1c9603..0822d13a9a 100644 --- a/csit.infra.etl/coverage_device_rls2210.py +++ b/csit.infra.etl/coverage_device_rls2210.py @@ -143,7 +143,7 @@ paths = wr.s3.list_objects( filtered_paths = [path for path in paths if "report-coverage-2210" in path] -out_sdf = process_json_to_dataframe("mrr", filtered_paths) +out_sdf = process_json_to_dataframe("device", filtered_paths) out_sdf.printSchema() out_sdf = out_sdf \ .withColumn("year", lit(datetime.now().year)) \