diff options
| author |   pmikus <peter.mikus@protonmail.ch> | 2022-12-07 13:11:10 +0000 |
|---|---|---|
| committer | Peter Mikus <peter.mikus@protonmail.ch> | 2022-12-09 10:37:24 +0000 |
| commit | 5f4aeffb078342604a3fb1be86d91e7a12750691 (patch) | |
| tree | 7b48c395644148e6c104c5d33d75b289119336f1 /csit.infra.etl/coverage_device_rls2210.py | |
| parent | 420226fcfd8cab460f632c1401d6012dc353f6fd (diff) | |
feat(etl): Reconf type
Signed-off-by: pmikus <peter.mikus@protonmail.ch>
Change-Id: I1ce012e22d715a7371d03c086bb83e17592bd4e3
Diffstat (limited to 'csit.infra.etl/coverage_device_rls2210.py')
| -rw-r--r-- | csit.infra.etl/coverage_device_rls2210.py | 2 |
1 files changed, 1 insertions, 1 deletions
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)) \ |