Code Review
/
csit.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
feat(model): Hoststack type
[csit.git]
/
csit.infra.etl
/
coverage_ndrpdr_rls2210.py
diff --git
a/csit.infra.etl/coverage_ndrpdr_rls2210.py
b/csit.infra.etl/coverage_ndrpdr_rls2210.py
index
9c9e1c9
..
c0bd1d3
100644
(file)
--- a/
csit.infra.etl/coverage_ndrpdr_rls2210.py
+++ b/
csit.infra.etl/coverage_ndrpdr_rls2210.py
@@
-143,7
+143,7
@@
paths = wr.s3.list_objects(
filtered_paths = [path for path in paths if "report-coverage-2210" in path]
filtered_paths = [path for path in paths if "report-coverage-2210" in path]
-out_sdf = process_json_to_dataframe("
mr
r", filtered_paths)
+out_sdf = process_json_to_dataframe("
ndrpd
r", filtered_paths)
out_sdf.printSchema()
out_sdf = out_sdf \
.withColumn("year", lit(datetime.now().year)) \
out_sdf.printSchema()
out_sdf = out_sdf \
.withColumn("year", lit(datetime.now().year)) \