浏览代码

Merge pull request #3475 from ThomasWaldmann/fix-borg-init-quota

borg init: use given --storage-quota for local repo, fixes #3470
TW 7 年之前
父节点
当前提交
ec8a8c0729
共有 1 个文件被更改,包括 3 次插入2 次删除
  1. 3 2
      src/borg/archiver.py

+ 3 - 2
src/borg/archiver.py

@@ -124,6 +124,7 @@ def with_repository(fake=False, invert_fake=False, create=False, lock=True,
         def wrapper(self, args, **kwargs):
         def wrapper(self, args, **kwargs):
             location = args.location  # note: 'location' must be always present in args
             location = args.location  # note: 'location' must be always present in args
             append_only = getattr(args, 'append_only', False)
             append_only = getattr(args, 'append_only', False)
+            storage_quota = getattr(args, 'storage_quota', None)
             if argument(args, fake) ^ invert_fake:
             if argument(args, fake) ^ invert_fake:
                 return method(self, args, repository=None, **kwargs)
                 return method(self, args, repository=None, **kwargs)
             elif location.proto == 'ssh':
             elif location.proto == 'ssh':
@@ -131,8 +132,8 @@ def with_repository(fake=False, invert_fake=False, create=False, lock=True,
                                               lock_wait=self.lock_wait, lock=lock, append_only=append_only, args=args)
                                               lock_wait=self.lock_wait, lock=lock, append_only=append_only, args=args)
             else:
             else:
                 repository = Repository(location.path, create=create, exclusive=argument(args, exclusive),
                 repository = Repository(location.path, create=create, exclusive=argument(args, exclusive),
-                                        lock_wait=self.lock_wait, lock=lock,
-                                        append_only=append_only)
+                                        lock_wait=self.lock_wait, lock=lock, append_only=append_only,
+                                        storage_quota=storage_quota)
             with repository:
             with repository:
                 if manifest or cache:
                 if manifest or cache:
                     kwargs['manifest'], kwargs['key'] = Manifest.load(repository, compatibility)
                     kwargs['manifest'], kwargs['key'] = Manifest.load(repository, compatibility)