Skip to content

Commit 02ccd47

Browse files
committed
Add method to flush skipped files from an rsyncer
1 parent 2f55ae6 commit 02ccd47

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/murfey/client/rsync.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -219,6 +219,10 @@ def enqueue(self, file_path: Path):
219219
absolute_path = self._basepath / file_path
220220
self.queue.put(absolute_path)
221221

222+
def flush_skipped(self):
223+
for f in self._skipped_files:
224+
self.queue.put(f)
225+
222226
def _process(self):
223227
logger.info("RSync thread starting")
224228
files_to_transfer: list[Path]

0 commit comments

Comments
 (0)