From 862fccf63424e3a5a677abce1ee1245ac2099cee Mon Sep 17 00:00:00 2001
From: haiqi96 <14502009+haiqi96@users.noreply.github.com>
Date: Mon, 15 Jul 2024 18:05:03 -0400
Subject: [PATCH] clp-package: Fix bugs introduced in #460: (#481)

- Write search results to collection named job_id rather than task_id.
- Convert int to str in IR extraction command generation.
---
 .../job_orchestration/executor/query/extract_ir_task.py         | 2 +-
 .../job_orchestration/executor/query/fs_search_task.py          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/components/job-orchestration/job_orchestration/executor/query/extract_ir_task.py b/components/job-orchestration/job_orchestration/executor/query/extract_ir_task.py
index b04b809f3..61fcbf549 100644
--- a/components/job-orchestration/job_orchestration/executor/query/extract_ir_task.py
+++ b/components/job-orchestration/job_orchestration/executor/query/extract_ir_task.py
@@ -45,7 +45,7 @@ def make_command(
         ]
         if extract_ir_config.target_uncompressed_size is not None:
             command.append("--target-size")
-            command.append(extract_ir_config.target_uncompressed_size)
+            command.append(str(extract_ir_config.target_uncompressed_size))
     else:
         logger.error(f"Unsupported storage engine {storage_engine}")
         return None
diff --git a/components/job-orchestration/job_orchestration/executor/query/fs_search_task.py b/components/job-orchestration/job_orchestration/executor/query/fs_search_task.py
index baafca3e2..162056220 100644
--- a/components/job-orchestration/job_orchestration/executor/query/fs_search_task.py
+++ b/components/job-orchestration/job_orchestration/executor/query/fs_search_task.py
@@ -129,7 +129,7 @@ def search(
         archive_id=archive_id,
         search_config=search_config,
         results_cache_uri=results_cache_uri,
-        results_collection=str(task_id),
+        results_collection=job_id,
     )
     if not task_command:
         return report_command_creation_failure(