diff options
Diffstat (limited to 'csit.infra.etl/iterative_ndrpdr_rls2410.py')
| -rw-r--r-- | csit.infra.etl/iterative_ndrpdr_rls2410.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/csit.infra.etl/iterative_ndrpdr_rls2410.py b/csit.infra.etl/iterative_ndrpdr_rls2410.py index 50f103ae60..dae1755670 100644 --- a/csit.infra.etl/iterative_ndrpdr_rls2410.py +++ b/csit.infra.etl/iterative_ndrpdr_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-29", + f"{datetime.now().year}-9-28", "%Y-%m-%d" ) ) @@ -154,7 +154,7 @@ out_sdf.printSchema() out_sdf = out_sdf \ .withColumn("year", lit(datetime.now().year)) \ .withColumn("month", lit("9")) \ - .withColumn("day", lit("29")) \ + .withColumn("day", lit("28")) \ .repartition(1) try: |