Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ async def setup(self) -> None:
task_name="volumes bookkeeping",
)
self._task_periodic_volume_cleanup = create_periodic_task(
self._bookkeeping_task,
self._periodic_volume_cleanup_task,
interval=self.volume_cleanup_interval,
task_name="volume cleanup",
)
Expand Down Expand Up @@ -96,7 +96,7 @@ async def _remove_volume_safe(
requires_backup=requires_backup,
)

async def _periodic_volmue_cleanup_task(self) -> None:
async def _periodic_volume_cleanup_task(self) -> None:
with log_context(_logger, logging.DEBUG, "volume cleanup"):
volumes_to_remove: set[str] = set()
for volume_name, inactive_since in self._unused_volumes.items():
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@ async def test_volumes_manager_periodic_task_cleanup(
):
async def _run_volumes_clennup() -> None:
await volumes_manager._bookkeeping_task() # noqa: SLF001
await volumes_manager._periodic_volmue_cleanup_task() # noqa: SLF001
await volumes_manager._periodic_volume_cleanup_task() # noqa: SLF001

await _run_volumes_clennup()
assert spy_remove_volume.call_count == 0
Expand Down
Loading