File tree Expand file tree Collapse file tree 2 files changed +6
-0
lines changed
Expand file tree Collapse file tree 2 files changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -223,6 +223,8 @@ class RSyncerInfo(BaseModel):
223223 source : str
224224 num_files_transferred : int
225225 num_files_in_queue : int
226+ alive : bool
227+ stopping : bool
226228
227229
228230@router .get ("/sessions/{session_id}/rsyncer_info" )
@@ -234,6 +236,8 @@ def get_rsyncer_info(session_id: MurfeySessionID) -> list[RSyncerInfo]:
234236 source = str (k ),
235237 num_files_transferred = v ._files_transferred ,
236238 num_files_in_queue = v .queue .qsize (),
239+ alive = v .thread .is_alive (),
240+ stopping = v ._stopping ,
237241 )
238242 )
239243 return info
Original file line number Diff line number Diff line change @@ -413,6 +413,8 @@ class RSyncerInfo(BaseModel):
413413 source : str
414414 num_files_transferred : int
415415 num_files_in_queue : int
416+ alive : bool
417+ stopping : bool
416418
417419
418420@router .get ("/instruments/{instrument_name}/sessions/{session_id}/rsyncer_info" )
You can’t perform that action at this time.
0 commit comments