Fix missing kwargs injection on upload blob call

fsspec · Jan 31, 2023 · b50be78 · b50be78
1 parent 47f6be2
commit b50be78
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/adlfs/spec.py b/adlfs/spec.py
@@ -1413,7 +1413,10 @@ async def _pipe_file(self, path, value, overwrite=True, **kwargs):
             container=container_name, blob=path
         ) as bc:
             result = await bc.upload_blob(
-                data=value, overwrite=overwrite, metadata={"is_directory": "false"}
+                data=value,
+                overwrite=overwrite,
+                metadata={"is_directory": "false"},
+                **kwargs,
             )
         self.invalidate_cache(self._parent(path))
         return result