aboutsummaryrefslogtreecommitdiffstats
path: root/csit.infra.etl
diff options
context:
space:
mode:
authorPeter Mikus <peter.mikus@protonmail.ch>2024-10-01 08:23:28 +0200
committerPeter Mikus <peter.mikus@protonmail.ch>2024-10-01 06:36:52 +0000
commit0c08e569e2217acc520c50ff13eddf19d2d3fdc3 (patch)
tree1f2684f2152067e5b0334004be519950ec22ffc9 /csit.infra.etl
parente1c7d3beff2648cd74fb35958df84369ab61bfe4 (diff)
test(etl): Manual run
Signed-off-by: Peter Mikus <peter.mikus@protonmail.ch> Change-Id: Iede2e71adbcdd6bebca567dc6d3560de05ea69f9
Diffstat (limited to 'csit.infra.etl')
-rw-r--r--csit.infra.etl/coverage_device_rls2410.py4
-rw-r--r--csit.infra.etl/coverage_hoststack_rls2410.py4
-rw-r--r--csit.infra.etl/coverage_mrr_rls2410.py4
-rw-r--r--csit.infra.etl/coverage_ndrpdr_rls2410.py4
-rw-r--r--csit.infra.etl/coverage_reconf_rls2410.py4
-rw-r--r--csit.infra.etl/coverage_soak_rls2410.py4
-rw-r--r--csit.infra.etl/iterative_hoststack_rls2410.py4
-rw-r--r--csit.infra.etl/iterative_mrr_rls2410.py4
-rw-r--r--csit.infra.etl/iterative_ndrpdr_rls2410.py4
-rw-r--r--csit.infra.etl/iterative_reconf_rls2410.py4
-rw-r--r--csit.infra.etl/iterative_soak_rls2410.py4
11 files changed, 22 insertions, 22 deletions
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: