ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-coverage-2306" in path]
+filtered_paths = [path for path in paths if "report-coverage-2310" in path]
out_sdf = process_json_to_dataframe("device", filtered_paths)
out_sdf.printSchema()
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-coverage-2306" in path]
+filtered_paths = [path for path in paths if "report-coverage-2310" in path]
out_sdf = process_json_to_dataframe("hoststack", filtered_paths)
out_sdf.show(truncate=False)
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-coverage-2306" in path]
+filtered_paths = [path for path in paths if "report-coverage-2310" in path]
out_sdf = process_json_to_dataframe("mrr", filtered_paths)
out_sdf.printSchema()
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-coverage-2306" in path]
+filtered_paths = [path for path in paths if "report-coverage-2310" in path]
out_sdf = process_json_to_dataframe("ndrpdr", filtered_paths)
out_sdf.printSchema()
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-coverage-2306" in path]
+filtered_paths = [path for path in paths if "report-coverage-2310" in path]
out_sdf = process_json_to_dataframe("reconf", filtered_paths)
out_sdf.show(truncate=False)
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-coverage-2306" in path]
+filtered_paths = [path for path in paths if "report-coverage-2310" in path]
out_sdf = process_json_to_dataframe("soak", filtered_paths)
out_sdf.printSchema()
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/coverage_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-iterative-2306" in path]
+filtered_paths = [path for path in paths if "report-iterative-2310" in path]
out_sdf = process_json_to_dataframe("hoststack", filtered_paths)
out_sdf.show(truncate=False)
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-iterative-2306" in path]
+filtered_paths = [path for path in paths if "report-iterative-2310" in path]
out_sdf = process_json_to_dataframe("mrr", filtered_paths)
out_sdf.printSchema()
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-iterative-2306" in path]
+filtered_paths = [path for path in paths if "report-iterative-2310" in path]
out_sdf = process_json_to_dataframe("ndrpdr", filtered_paths)
out_sdf.printSchema()
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-iterative-2306" in path]
+filtered_paths = [path for path in paths if "report-iterative-2310" in path]
out_sdf = process_json_to_dataframe("reconf", filtered_paths)
out_sdf.show(truncate=False)
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
ignore_empty=True
)
-filtered_paths = [path for path in paths if "report-iterative-2306" in path]
+filtered_paths = [path for path in paths if "report-iterative-2310" in path]
out_sdf = process_json_to_dataframe("soak", filtered_paths)
out_sdf.printSchema()
try:
wr.s3.to_parquet(
df=out_sdf.toPandas(),
- path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2306",
+ path=f"s3://{S3_DOCS_BUCKET}/csit/parquet/iterative_rls2310",
dataset=True,
partition_cols=["test_type", "year", "month", "day"],
compression="snappy",
| Name | Version |
|------|---------|
-| <a name="requirement_terraform"></a> [terraform](#requirement\_terraform) | >= 1.1.4 |
-| <a name="requirement_nomad"></a> [nomad](#requirement\_nomad) | >= 1.4.16 |
+| <a name="requirement_terraform"></a> [terraform](#requirement\_terraform) | >= 1.5.4 |
+| <a name="requirement_nomad"></a> [nomad](#requirement\_nomad) | >= 1.4.20 |
## Providers
| Name | Version |
|------|---------|
-| <a name="provider_nomad"></a> [nomad](#provider\_nomad) | >= 1.4.16 |
+| <a name="provider_nomad"></a> [nomad](#provider\_nomad) | >= 1.4.20 |
## Modules
| Name | Type |
|------|------|
-| [nomad_job.nomad_job_etl](https://registry.terraform.io/providers/hashicorp/nomad/latest/docs/resources/job) | resource |
+| [nomad_job.nomad_job](https://registry.terraform.io/providers/hashicorp/nomad/latest/docs/resources/job) | resource |
## Inputs
| <a name="input_envs"></a> [envs](#input\_envs) | Specifies ETL environment variables. | `list(string)` | `[]` | no |
| <a name="input_image"></a> [image](#input\_image) | Specifies the Docker image to run. | `string` | `"pmikus/docker-ubuntu-focal-aws-glue:latest"` | no |
| <a name="input_job_name"></a> [job\_name](#input\_job\_name) | Specifies a name for the job. | `string` | `"etl"` | no |
-| <a name="input_memory"></a> [memory](#input\_memory) | Specifies the memory required in MB. | `number` | `20000` | no |
+| <a name="input_memory"></a> [memory](#input\_memory) | Specifies the memory required in MB. | `number` | `50000` | no |
| <a name="input_out_aws_access_key_id"></a> [out\_aws\_access\_key\_id](#input\_out\_aws\_access\_key\_id) | AWS access key. | `string` | `"aws"` | no |
| <a name="input_out_aws_default_region"></a> [out\_aws\_default\_region](#input\_out\_aws\_default\_region) | AWS region | `string` | `"aws"` | no |
| <a name="input_out_aws_secret_access_key"></a> [out\_aws\_secret\_access\_key](#input\_out\_aws\_secret\_access\_key) | AWS secret key | `string` | `"aws"` | no |
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "coverage_device_rls2306.py"
+ "coverage_device_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "coverage_hoststack_rls2306.py"
+ "coverage_hoststack_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "coverage_mrr_rls2306.py"
+ "coverage_mrr_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "coverage_reconf_rls2306.py"
+ "coverage_ndrpdr_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "coverage_ndrpdr_rls2306.py"
+ "coverage_reconf_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "coverage_soak_rls2306.py"
+ "coverage_soak_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "iterative_hoststack_rls2306.py"
+ "iterative_hoststack_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "iterative_mrr_rls2306.py"
+ "iterative_mrr_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "iterative_ndrpdr_rls2306.py"
+ "iterative_ndrpdr_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "iterative_reconf_rls2306.py"
+ "iterative_reconf_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
"--executor-memory", "20g",
"--executor-cores", "2",
"--master", "local[2]",
- "iterative_soak_rls2306.py"
+ "iterative_soak_rls2310.py"
]
work_dir = "/local/csit/csit.infra.etl"
}
job_name = "etl-trending-ndrpdr"
}
-module "etl-iterative-hoststack-rls2306" {
+module "etl-iterative-hoststack-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-iterative-hoststack-rls2306"
+ job_name = "etl-iterative-hoststack-rls2310"
}
-module "etl-iterative-mrr-rls2306" {
+module "etl-iterative-mrr-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-iterative-mrr-rls2306"
+ job_name = "etl-iterative-mrr-rls2310"
}
-module "etl-iterative-ndrpdr-rls2306" {
+module "etl-iterative-ndrpdr-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-iterative-ndrpdr-rls2306"
+ job_name = "etl-iterative-ndrpdr-rls2310"
}
-module "etl-iterative-reconf-rls2306" {
+module "etl-iterative-reconf-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-iterative-reconf-rls2306"
+ job_name = "etl-iterative-reconf-rls2310"
}
-module "etl-iterative-soak-rls2306" {
+module "etl-iterative-soak-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-iterative-soak-rls2306"
+ job_name = "etl-iterative-soak-rls2310"
}
-module "etl-coverage-device-rls2306" {
+module "etl-coverage-device-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-coverage-device-rls2306"
+ job_name = "etl-coverage-device-rls2310"
}
-module "etl-coverage-hoststack-rls2306" {
+module "etl-coverage-hoststack-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-coverage-hoststack-rls2306"
+ job_name = "etl-coverage-hoststack-rls2310"
}
-module "etl-coverage-mrr-rls2306" {
+module "etl-coverage-mrr-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-coverage-mrr-rls2306"
+ job_name = "etl-coverage-mrr-rls2310"
}
-module "etl-coverage-ndrpdr-rls2306" {
+module "etl-coverage-ndrpdr-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-coverage-ndrpdr-rls2306"
+ job_name = "etl-coverage-ndrpdr-rls2310"
}
-module "etl-coverage-reconf-rls2306" {
+module "etl-coverage-reconf-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-coverage-reconf-rls2306"
+ job_name = "etl-coverage-reconf-rls2310"
}
-module "etl-coverage-soak-rls2306" {
+module "etl-coverage-soak-rls2310" {
providers = {
nomad = nomad.yul1
}
out_aws_default_region = data.vault_generic_secret.fdio_docs.data["region"]
cron = "@daily"
datacenters = ["yul1"]
- job_name = "etl-coverage-soak-rls2306"
+ job_name = "etl-coverage-soak-rls2310"
}
required_providers {
nomad = {
source = "hashicorp/nomad"
- version = ">= 1.4.19"
+ version = ">= 1.4.20"
}
vault = {
version = ">= 3.12.0"
}
}
- required_version = ">= 1.3.7"
+ required_version = ">= 1.5.4"
}
required_providers {
nomad = {
source = "hashicorp/nomad"
- version = ">= 1.4.19"
+ version = ">= 1.4.20"
}
}
- required_version = ">= 1.3.7"
+ required_version = ">= 1.5.4"
}