@@ -114,12 +114,13 @@ async def get_async_job_status(request: web.Request) -> web.Response:
114114 _req_ctx = AuthenticatedRequestContext .model_validate (request )
115115 path_params = parse_request_path_parameters_as (_PathParams , request )
116116
117- task_filter = get_job_filter (
118- user_id = _req_ctx .user_id ,
119- product_name = _req_ctx .product_name ,
120- )
121117 task_status = await get_task_manager (request .app ).get_task_status (
122- task_filter = TaskFilter .model_validate (task_filter ),
118+ task_filter = TaskFilter .model_validate (
119+ get_job_filter (
120+ user_id = _req_ctx .user_id ,
121+ product_name = _req_ctx .product_name ,
122+ )
123+ ),
123124 task_uuid = path_params .task_id ,
124125 )
125126
@@ -147,13 +148,13 @@ async def cancel_async_job(request: web.Request) -> web.Response:
147148 _req_ctx = AuthenticatedRequestContext .model_validate (request )
148149 path_params = parse_request_path_parameters_as (_PathParams , request )
149150
150- task_manager = get_task_manager (request .app )
151- task_filter = get_job_filter (
152- user_id = _req_ctx . user_id ,
153- product_name = _req_ctx .product_name ,
154- )
155- await task_manager . cancel_task (
156- task_filter = TaskFilter . model_validate ( task_filter ),
151+ await get_task_manager (request .app ). cancel_task (
152+ task_filter = TaskFilter . model_validate (
153+ get_job_filter (
154+ user_id = _req_ctx .user_id ,
155+ product_name = _req_ctx . product_name ,
156+ )
157+ ),
157158 task_uuid = path_params .task_id ,
158159 )
159160
@@ -171,12 +172,13 @@ async def get_async_job_result(request: web.Request) -> web.Response:
171172 _req_ctx = AuthenticatedRequestContext .model_validate (request )
172173 path_params = parse_request_path_parameters_as (_PathParams , request )
173174
174- task_filter = get_job_filter (
175- user_id = _req_ctx .user_id ,
176- product_name = _req_ctx .product_name ,
177- )
178175 task_result = await get_task_manager (request .app ).get_task_result (
179- task_filter = TaskFilter .model_validate (task_filter ),
176+ task_filter = TaskFilter .model_validate (
177+ get_job_filter (
178+ user_id = _req_ctx .user_id ,
179+ product_name = _req_ctx .product_name ,
180+ )
181+ ),
180182 task_uuid = path_params .task_id ,
181183 )
182184
0 commit comments