Skip to content

Commit fd66aba

Browse files
committed
fix: disk pressure: wait for jobs before processing other filesystem events
1 parent 615e5b3 commit fd66aba

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/autofastdl/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = "0.1.1"
1+
__version__ = "0.1.2"

src/autofastdl/autofastdl.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -758,10 +758,10 @@ def __exit__(
758758
def Loop(self) -> None:
759759
self.NotifyNotifier.process_events()
760760
while self.NotifyNotifier.check_events():
761+
jobs.join()
761762
self.NotifyNotifier.read_events()
762763
self.NotifyNotifier.process_events()
763764
jobs.join()
764-
# Make sure that only one CheckAllFiles is running at all times
765765
jobs.put(
766766
(
767767
AsyncFunc.CheckAllFiles,

0 commit comments

Comments
 (0)