From ff15840ce1afc85a86f7c12beb0ecce32afa0925 Mon Sep 17 00:00:00 2001 From: Haiqi Xu <14502009+haiqi96@users.noreply.github.com> Date: Fri, 15 Nov 2024 15:52:11 -0500 Subject: [PATCH] fix for previous commit (again) --- .../job_orchestration/executor/query/fs_search_task.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 162056220..598bfdcfc 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 @@ -98,7 +98,7 @@ def search( self: Task, job_id: str, task_id: int, - job_config_obj: dict, + job_config: dict, archive_id: str, clp_metadata_db_conn_params: dict, results_cache_uri: str, @@ -120,7 +120,7 @@ def search( clp_home = Path(os.getenv("CLP_HOME")) archive_directory = Path(os.getenv("CLP_ARCHIVE_OUTPUT_DIR")) clp_storage_engine = os.getenv("CLP_STORAGE_ENGINE") - search_config = SearchJobConfig.parse_obj(job_config_obj) + search_config = SearchJobConfig.parse_obj(job_config) task_command = make_command( storage_engine=clp_storage_engine,