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 fdd05263b..a5dbc0e35 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
@@ -181,8 +181,8 @@ def run_clp(
     enable_s3_write = False
     storage_type = worker_config.archive_output.storage.type
     if StorageType.S3 == storage_type:
-        if StorageEngine.CLP == clp_storage_engine:
-            error_msg = f"S3 storage is not supported for the {clp_storage_engine} storage engine."
+        if StorageEngine.CLP_S != clp_storage_engine:
+            error_msg = f"S3 storage is not supported for storage engine: {clp_storage_engine}."
             logger.error(error_msg)
             return False, {"error_message": error_msg}