Skip to content

Commit

Permalink
Minor error message fix
Browse files Browse the repository at this point in the history
  • Loading branch information
dachengx committed Jun 9, 2024
1 parent c6d86b3 commit 9794f65
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 3 deletions.
7 changes: 5 additions & 2 deletions strax/mailbox.py
Original file line number Diff line number Diff line change
Expand Up @@ -244,8 +244,11 @@ def _can_fetch(self):

# Everyone is waiting for the new chunk or not at all.
# Fetch only if a driver is waiting.
for _i, waiting_for in enumerate(self._subscriber_waiting_for):
if self._subscriber_can_drive[_i] and waiting_for is not None:
for can_drive, waiting_for in zip(
self._subscriber_can_drive,
self._subscriber_waiting_for,
):
if can_drive and waiting_for is not None:
return True
return False

Expand Down
2 changes: 1 addition & 1 deletion strax/storage/files.py
Original file line number Diff line number Diff line change
Expand Up @@ -306,7 +306,7 @@ def __init__(self, dirname, metadata, **kwargs):
print(f"Removing data in {dirname} to overwrite")
shutil.rmtree(dirname)
if os.path.exists(self.tempdirname):
print(f"Removing old incomplete data in {dirname}")
print(f"Removing old incomplete data in {self.tempdirname}")
shutil.rmtree(self.tempdirname)
os.makedirs(self.tempdirname)
self._flush_metadata()
Expand Down

0 comments on commit 9794f65

Please sign in to comment.