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(