diff --git a/virtnbdbackup b/virtnbdbackup
index 9fb0d0a4..da869021 100755
--- a/virtnbdbackup
+++ b/virtnbdbackup
@@ -495,7 +495,7 @@ def main() -> None:
         with ThreadPoolExecutor(max_workers=args.worker) as executor:
             futures = {
                 executor.submit(
-                    backupDisk, args, disk, count, fileStream, virtClient
+                    backupDisk, args, disk, count, repository, virtClient
                 ): disk
                 for count, disk in enumerate(disks)
             }
@@ -656,10 +656,11 @@ def backupDisk(
     args: Namespace,
     disk: DomainDisk,
     count: int,
-    fileStream,
+    repository,
     virtClient: virt.client,
 ):
     """Backup domain disk data."""
+    fileStream = stream.get(args, repository)
     dStream = streamer.SparseStream(types)
     sTypes = types.SparseStreamTypes()
     current_thread().name = disk.target