File tree Expand file tree Collapse file tree 1 file changed +12
-0
lines changed Expand file tree Collapse file tree 1 file changed +12
-0
lines changed Original file line number Diff line number Diff line change 77from typing import Annotated , Any
88
99from fastapi import APIRouter , Depends , status
10+ from fastapi .responses import StreamingResponse
1011from models_library .generics import Envelope
1112from models_library .rest_error import EnvelopedError
1213from servicelib .aiohttp .long_running_tasks ._routes import _PathParam
@@ -49,6 +50,17 @@ def get_async_job_status(
4950 """Retrieves the status of a task"""
5051
5152
53+ @router .get (
54+ "/tasks/{task_id}/stream" ,
55+ response_model = StreamingResponse ,
56+ responses = _export_data_responses ,
57+ )
58+ def get_async_job_stream (
59+ _path_params : Annotated [_PathParam , Depends ()],
60+ ):
61+ """Retrieves the stream of a task"""
62+
63+
5264@router .delete (
5365 "/tasks/{task_id}" ,
5466 responses = _export_data_responses ,
You can’t perform that action at this time.
0 commit comments