diff --git a/graphrag/storage/blob_pipeline_storage.py b/graphrag/storage/blob_pipeline_storage.py
index c7081644e8..a92835cb26 100644
--- a/graphrag/storage/blob_pipeline_storage.py
+++ b/graphrag/storage/blob_pipeline_storage.py
@@ -290,13 +290,12 @@ def _abfs_url(self, key: str) -> str:
         return f"abfs://{path}"
 
 
-def create_blob_storage(
-    connection_string: str | None,
-    storage_account_blob_url: str | None,
-    container_name: str,
-    base_dir: str | None,
-) -> PipelineStorage:
+def create_blob_storage(**kwargs: Any) -> PipelineStorage:
     """Create a blob based storage."""
+    connection_string = kwargs["connection_string"]
+    storage_account_blob_url = kwargs["storage_account_blob_url"]
+    container_name = kwargs["container_name"]
+    base_dir = kwargs["base_dir"]
     log.info("Creating blob storage at %s", container_name)
     if container_name is None:
         msg = "No container name provided for blob storage."