X-Git-Url: https://gerrit.fd.io/r/gitweb?p=csit.git;a=blobdiff_plain;f=csit.infra.etl%2Fiterative_ndrpdr_rls2402.py;fp=csit.infra.etl%2Fiterative_ndrpdr_rls2310.py;h=9231176e1051f21cfed63279632abf1fbb070a14;hp=d368c4a8fc7bb91ba079f1e80c341e7effb80dda;hb=2a242e5b87bcb3117f262864e7547e63147250c5;hpb=1191a01f7981d37577ee872614274e88e3522db4 diff --git a/csit.infra.etl/iterative_ndrpdr_rls2310.py b/csit.infra.etl/iterative_ndrpdr_rls2402.py similarity index 98% rename from csit.infra.etl/iterative_ndrpdr_rls2310.py rename to csit.infra.etl/iterative_ndrpdr_rls2402.py index d368c4a8fc..9231176e10 100644 --- a/csit.infra.etl/iterative_ndrpdr_rls2310.py +++ b/csit.infra.etl/iterative_ndrpdr_rls2402.py @@ -141,7 +141,7 @@ paths = wr.s3.list_objects( ignore_empty=True ) -filtered_paths = [path for path in paths if "report-iterative-2310" in path] +filtered_paths = [path for path in paths if "report-iterative-2402" in path] out_sdf = process_json_to_dataframe("ndrpdr", filtered_paths) out_sdf.printSchema() @@ -154,7 +154,7 @@ out_sdf = out_sdf \ try: wr.s3.to_parquet( df=out_sdf.toPandas(), - path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2310", + path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2402", dataset=True, partition_cols=["test_type", "year", "month", "day"], compression="snappy",