fix: black
This commit is contained in:
+8
-2
@@ -52,6 +52,7 @@ def main():
|
|||||||
# TODO print time estimation while scrub is in progress
|
# TODO print time estimation while scrub is in progress
|
||||||
# skip send when sender and receiver snapshots are equal
|
# skip send when sender and receiver snapshots are equal
|
||||||
|
|
||||||
|
|
||||||
class Manager:
|
class Manager:
|
||||||
def __init__(self, local_pool: Pool, external_pool: ExternalPool):
|
def __init__(self, local_pool: Pool, external_pool: ExternalPool):
|
||||||
self._local_pool = local_pool
|
self._local_pool = local_pool
|
||||||
@@ -111,7 +112,9 @@ class Manager:
|
|||||||
return dataset
|
return dataset
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
def _get_last_common_snapshot(cls, local_dataset: Dataset, remote_dataset: Dataset) -> Snapshot:
|
def _get_last_common_snapshot(
|
||||||
|
cls, local_dataset: Dataset, remote_dataset: Dataset
|
||||||
|
) -> Snapshot:
|
||||||
common_snapshots = [
|
common_snapshots = [
|
||||||
local_snap
|
local_snap
|
||||||
for local_snap in list(cls._find_snapshots_with_backup_tag(local_dataset))
|
for local_snap in list(cls._find_snapshots_with_backup_tag(local_dataset))
|
||||||
@@ -280,6 +283,7 @@ class ZFS:
|
|||||||
if wait_for_finish:
|
if wait_for_finish:
|
||||||
# TODO make Ctrl-c interrupt this
|
# TODO make Ctrl-c interrupt this
|
||||||
run_command([config.ZPOOL, "wait", "-t", "scrub", pool])
|
run_command([config.ZPOOL, "wait", "-t", "scrub", pool])
|
||||||
|
|
||||||
# TODO raise error if pool is not healthy
|
# TODO raise error if pool is not healthy
|
||||||
|
|
||||||
|
|
||||||
@@ -444,7 +448,9 @@ class Dataset:
|
|||||||
for snapshot in old_snapshots:
|
for snapshot in old_snapshots:
|
||||||
snapshot.destroy()
|
snapshot.destroy()
|
||||||
|
|
||||||
def _get_n_oldest_snapshots(self, snapshots: list[Snapshot], count: int) -> list[Snapshot]:
|
def _get_n_oldest_snapshots(
|
||||||
|
self, snapshots: list[Snapshot], count: int
|
||||||
|
) -> list[Snapshot]:
|
||||||
snapshots.sort()
|
snapshots.sort()
|
||||||
return snapshots[:count]
|
return snapshots[:count]
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user