diff --git a/src/components/persistentStorage/PersistentStorageFactory.ts b/src/components/persistentStorage/PersistentStorageFactory.ts
index fbd85c7de..c00baf151 100644
--- a/src/components/persistentStorage/PersistentStorageFactory.ts
+++ b/src/components/persistentStorage/PersistentStorageFactory.ts
@@ -179,7 +179,7 @@ export abstract class PersistentStorageFactory {
   public abstract getDockerMountObject(
     bucketId: string,
     fileName: string,
-    consumerAddress?: string
+    consumerAddress: string
   ): Promise<DockerMountObject>
 
   public abstract getDockerOutputMountObject(
diff --git a/src/components/persistentStorage/PersistentStorageLocalFS.ts b/src/components/persistentStorage/PersistentStorageLocalFS.ts
index 92407c21a..92ac36698 100644
--- a/src/components/persistentStorage/PersistentStorageLocalFS.ts
+++ b/src/components/persistentStorage/PersistentStorageLocalFS.ts
@@ -208,7 +208,7 @@ export class PersistentStorageLocalFS extends PersistentStorageFactory {
   async getDockerMountObject(
     bucketId: string,
     fileName: string,
-    consumerAddress?: string
+    consumerAddress: string
   ): Promise<DockerMountObject> {
     await this.ensureBucketExists(bucketId)
     if (!consumerAddress) {
diff --git a/src/components/persistentStorage/PersistentStorageS3.ts b/src/components/persistentStorage/PersistentStorageS3.ts
index 155c5a9ab..f5c9912b0 100644
--- a/src/components/persistentStorage/PersistentStorageS3.ts
+++ b/src/components/persistentStorage/PersistentStorageS3.ts
@@ -80,7 +80,7 @@ export class PersistentStorageS3 extends PersistentStorageFactory {
   async getDockerMountObject(
     _bucketId: string,
     _fileName: string,
-    _consumerAddress?: string
+    _consumerAddress: string
   ): Promise<DockerMountObject> {
     throw new Error('PersistentStorageS3 is not implemented yet')
   }
diff --git a/src/test/integration/persistentStorage.test.ts b/src/test/integration/persistentStorage.test.ts
index 4bfb89a8c..1b40d6fc8 100644
--- a/src/test/integration/persistentStorage.test.ts
+++ b/src/test/integration/persistentStorage.test.ts
@@ -166,7 +166,7 @@ describe('**********         Persistent storage handlers (integration)', functio
         ownerAddress
       )
 
-      const mount = await backend.getDockerMountObject(bucketId, fileName)
+      const mount = await backend.getDockerMountObject(bucketId, fileName, ownerAddress)
       expect(path.isAbsolute(mount.Source)).to.equal(true)
     } finally {
       await fsp.rm(path.resolve(relativeFolder), { recursive: true, force: true })