X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=csit.infra.etl%2Fiterative_ndrpdr_rls2306.py;fp=csit.infra.etl%2Fiterative_ndrpdr_rls2302.py;h=9b3a36be1824f13815600e4a160473f74404c399;hb=d164bef0373edfd2b6cc7d4aaa27b928065df3e5;hp=81e6f489c2de8e27362f2a1823a020778058def4;hpb=1fd3d96de221e7bf281f7ce96dc5cad0170a602d;p=csit.git diff --git a/csit.infra.etl/iterative_ndrpdr_rls2302.py b/csit.infra.etl/iterative_ndrpdr_rls2306.py similarity index 99% rename from csit.infra.etl/iterative_ndrpdr_rls2302.py rename to csit.infra.etl/iterative_ndrpdr_rls2306.py index 81e6f489c2..9b3a36be18 100644 --- a/csit.infra.etl/iterative_ndrpdr_rls2302.py +++ b/csit.infra.etl/iterative_ndrpdr_rls2306.py @@ -141,7 +141,7 @@ paths = wr.s3.list_objects( ignore_empty=True ) -filtered_paths = [path for path in paths if "report-iterative-2302" in path] +filtered_paths = [path for path in paths if "report-iterative-2306" 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_rls2302", + path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2306", dataset=True, partition_cols=["test_type", "year", "month", "day"], compression="snappy",