@@ -171,7 +171,7 @@ def restart(self):
171171 self .start ()
172172
173173 def stop (self ):
174- logger .info (" RSync thread stop requested " )
174+ logger .info (f"Stopping RSync thread { self } " )
175175 self ._stopping = True
176176 if self .thread .is_alive ():
177177 logger .info ("Waiting for ongoing transfers to complete..." )
@@ -181,7 +181,7 @@ def stop(self):
181181 if self .thread .is_alive ():
182182 self .queue .put (None )
183183 self .thread .join ()
184- logger .info ("RSync thread successfully stopped" )
184+ logger .info (f "RSync thread { self } successfully stopped" )
185185
186186 def request_stop (self ):
187187 self ._stopping = True
@@ -199,7 +199,7 @@ def finalise(
199199 self ._finalising = True
200200
201201 # Perform recursive cleanup on current directory
202- logger .info ("File cleanup started for RSync thread" )
202+ logger .info (f"Starting file cleanup for RSync thread { self } " )
203203 files_to_transfer : list [Path ] = []
204204
205205 def recursive_cleanup (dirpath : str | Path ):
@@ -242,7 +242,7 @@ def recursive_cleanup(dirpath: str | Path):
242242 else :
243243 self ._transfer (files_to_transfer )
244244 self ._finalised = True
245- logger .info ("File cleanup for RSync thread successfully completed" )
245+ logger .info (f "File cleanup for RSync thread { self } successfully completed" )
246246 if callback :
247247 callback ()
248248
@@ -257,7 +257,7 @@ def flush_skipped(self):
257257 self ._skipped_files = []
258258
259259 def _process (self ):
260- logger .info ("Starting RSync thread main process loop" )
260+ logger .info (f "Starting main process loop for RSync thread { self } " )
261261 files_to_transfer : list [Path ]
262262 backoff = 0
263263 while not self ._halt_thread :
0 commit comments