File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed
services/web/server/src/simcore_service_webserver/tasks Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -198,14 +198,14 @@ async def get_async_job_stream(request: web.Request) -> web.Response:
198198 path_params = parse_request_path_parameters_as (_PathParams , request )
199199 header_params = parse_request_headers_as (SSEHeaders , request )
200200
201- task_filter = get_job_filter (
202- user_id = _req_ctx .user_id ,
203- product_name = _req_ctx .product_name ,
204- )
205-
206201 async def event_generator ():
207202 async for event_id , event in get_task_manager (request .app ).consume_task_events (
208- task_filter = TaskFilter .model_validate (task_filter .model_dump ()),
203+ task_filter = TaskFilter .model_validate (
204+ get_job_filter (
205+ user_id = _req_ctx .user_id ,
206+ product_name = _req_ctx .product_name ,
207+ )
208+ ),
209209 task_uuid = path_params .task_id ,
210210 last_id = header_params .last_event_id ,
211211 ):
You can’t perform that action at this time.
0 commit comments