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 @@ -236,6 +236,8 @@ class RSyncerInfo(BaseModel):
236236 source : str
237237 num_files_transferred : int
238238 num_files_in_queue : int
239+ alive : bool
240+ stopping : bool
239241
240242
241243@router .get ("/sessions/{session_id}/rsyncer_info" )
@@ -247,6 +249,8 @@ def get_rsyncer_info(session_id: MurfeySessionID) -> list[RSyncerInfo]:
247249 source = str (k ),
248250 num_files_transferred = v ._files_transferred ,
249251 num_files_in_queue = v .queue .qsize (),
252+ alive = v .thread .is_alive (),
253+ stopping = v ._stopping ,
250254 )
251255 )
252256 return info
Original file line number Diff line number Diff line change @@ -434,6 +434,8 @@ class RSyncerInfo(BaseModel):
434434 source : str
435435 num_files_transferred : int
436436 num_files_in_queue : int
437+ alive : bool
438+ stopping : bool
437439
438440
439441@router .get ("/instruments/{instrument_name}/sessions/{session_id}/rsyncer_info" )
You can’t perform that action at this time.
0 commit comments