From 6ff92fc312476a0a12f2e48b1a7e3449aaca7a4e Mon Sep 17 00:00:00 2001 From: Haiqi Xu <14502009+haiqi96@users.noreply.github.com> Date: Tue, 17 Dec 2024 20:07:34 -0500 Subject: [PATCH] Clean up --- components/clp-py-utils/clp_py_utils/clp_config.py | 8 ++++---- .../executor/compress/fs_compression_task.py | 1 - 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/components/clp-py-utils/clp_py_utils/clp_config.py b/components/clp-py-utils/clp_py_utils/clp_config.py index 4d5ba7a47..f59de7647 100644 --- a/components/clp-py-utils/clp_py_utils/clp_config.py +++ b/components/clp-py-utils/clp_py_utils/clp_config.py @@ -320,19 +320,19 @@ class S3Config(BaseModel): @validator("region_code") def validate_region_code(cls, field): if field == "": - raise ValueError("region_code can not be empty") + raise ValueError("region_code cannot be empty") return field @validator("bucket") def validate_bucket(cls, field): if field == "": - raise ValueError("bucket can not be empty") + raise ValueError("bucket cannot be empty") return field @validator("key_prefix") def validate_key_prefix(cls, field): if field == "": - raise ValueError("key_prefix can not be empty") + raise ValueError("key_prefix cannot be empty") if not field.endswith("/"): raise ValueError('key_prefix must end with "/"') return field @@ -442,7 +442,7 @@ class StreamOutput(BaseModel): @validator("directory") def validate_directory(cls, field): if "" == field: - raise ValueError("directory can not be empty") + raise ValueError("directory cannot be empty") return field @validator("target_uncompressed_size") diff --git a/components/job-orchestration/job_orchestration/executor/compress/fs_compression_task.py b/components/job-orchestration/job_orchestration/executor/compress/fs_compression_task.py index 4fc949ab9..57b3ca3d5 100644 --- a/components/job-orchestration/job_orchestration/executor/compress/fs_compression_task.py +++ b/components/job-orchestration/job_orchestration/executor/compress/fs_compression_task.py @@ -26,7 +26,6 @@ from job_orchestration.scheduler.constants import CompressionTaskStatus from job_orchestration.scheduler.job_config import ClpIoConfig, PathsToCompress from job_orchestration.scheduler.scheduler_data import CompressionTaskResult -from result import is_err, Result # Setup logging logger = get_task_logger(__name__)