From 0c08e569e2217acc520c50ff13eddf19d2d3fdc3 Mon Sep 17 00:00:00 2001 From: Peter Mikus Date: Tue, 1 Oct 2024 08:23:28 +0200 Subject: test(etl): Manual run Signed-off-by: Peter Mikus Change-Id: Iede2e71adbcdd6bebca567dc6d3560de05ea69f9 --- csit.infra.etl/coverage_device_rls2410.py | 4 ++-- csit.infra.etl/coverage_hoststack_rls2410.py | 4 ++-- csit.infra.etl/coverage_mrr_rls2410.py | 4 ++-- csit.infra.etl/coverage_ndrpdr_rls2410.py | 4 ++-- csit.infra.etl/coverage_reconf_rls2410.py | 4 ++-- csit.infra.etl/coverage_soak_rls2410.py | 4 ++-- csit.infra.etl/iterative_hoststack_rls2410.py | 4 ++-- csit.infra.etl/iterative_mrr_rls2410.py | 4 ++-- csit.infra.etl/iterative_ndrpdr_rls2410.py | 4 ++-- csit.infra.etl/iterative_reconf_rls2410.py | 4 ++-- csit.infra.etl/iterative_soak_rls2410.py | 4 ++-- 11 files changed, 22 insertions(+), 22 deletions(-) (limited to 'csit.infra.etl') diff --git a/csit.infra.etl/coverage_device_rls2410.py b/csit.infra.etl/coverage_device_rls2410.py index d58df77f28..3a0a632f67 100644 --- a/csit.infra.etl/coverage_device_rls2410.py +++ b/csit.infra.etl/coverage_device_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/coverage_hoststack_rls2410.py b/csit.infra.etl/coverage_hoststack_rls2410.py index d1f562a563..abed41694c 100644 --- a/csit.infra.etl/coverage_hoststack_rls2410.py +++ b/csit.infra.etl/coverage_hoststack_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/coverage_mrr_rls2410.py b/csit.infra.etl/coverage_mrr_rls2410.py index 77e9479d14..e73cdbb603 100644 --- a/csit.infra.etl/coverage_mrr_rls2410.py +++ b/csit.infra.etl/coverage_mrr_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/coverage_ndrpdr_rls2410.py b/csit.infra.etl/coverage_ndrpdr_rls2410.py index 132222e294..d675ede96d 100644 --- a/csit.infra.etl/coverage_ndrpdr_rls2410.py +++ b/csit.infra.etl/coverage_ndrpdr_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/coverage_reconf_rls2410.py b/csit.infra.etl/coverage_reconf_rls2410.py index c5bd9e6e0a..2f51eaebfb 100644 --- a/csit.infra.etl/coverage_reconf_rls2410.py +++ b/csit.infra.etl/coverage_reconf_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/coverage_soak_rls2410.py b/csit.infra.etl/coverage_soak_rls2410.py index 2591c8d224..d89b11b602 100644 --- a/csit.infra.etl/coverage_soak_rls2410.py +++ b/csit.infra.etl/coverage_soak_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/iterative_hoststack_rls2410.py b/csit.infra.etl/iterative_hoststack_rls2410.py index fd9b442a2f..9489d3b321 100644 --- a/csit.infra.etl/iterative_hoststack_rls2410.py +++ b/csit.infra.etl/iterative_hoststack_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/iterative_mrr_rls2410.py b/csit.infra.etl/iterative_mrr_rls2410.py index 42710747f9..50557fc4d8 100644 --- a/csit.infra.etl/iterative_mrr_rls2410.py +++ b/csit.infra.etl/iterative_mrr_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/iterative_ndrpdr_rls2410.py b/csit.infra.etl/iterative_ndrpdr_rls2410.py index dae1755670..5835fa4c8c 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-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/iterative_reconf_rls2410.py b/csit.infra.etl/iterative_reconf_rls2410.py index 9f28ebb955..0781da21b9 100644 --- a/csit.infra.etl/iterative_reconf_rls2410.py +++ b/csit.infra.etl/iterative_reconf_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%Y-%m-%d" ) ) @@ -155,7 +155,7 @@ out_sdf.printSchema() out_sdf = out_sdf \ .withColumn("year", lit(datetime.now().year)) \ .withColumn("month", lit("9")) \ - .withColumn("day", lit("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: diff --git a/csit.infra.etl/iterative_soak_rls2410.py b/csit.infra.etl/iterative_soak_rls2410.py index a3b02bc170..6388b8cdd0 100644 --- a/csit.infra.etl/iterative_soak_rls2410.py +++ b/csit.infra.etl/iterative_soak_rls2410.py @@ -49,7 +49,7 @@ IGNORE_SUFFIX=[ #) LAST_MODIFIED_END=utc.localize( datetime.strptime( - f"{datetime.now().year}-9-28", + f"{datetime.now().year}-9-27", "%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("28")) \ + .withColumn("day", lit("27")) \ .repartition(1) try: -- cgit