Skip to content

Commit

Permalink
Update blob_pipeline_storage.py
Browse files Browse the repository at this point in the history
PR for issue microsoft#1538
  • Loading branch information
intelligencecompany authored Dec 19, 2024
1 parent c1c09ba commit 9df4ba0
Showing 1 changed file with 5 additions and 6 deletions.
11 changes: 5 additions & 6 deletions graphrag/storage/blob_pipeline_storage.py
Original file line number Diff line number Diff line change
Expand Up @@ -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."
Expand Down

0 comments on commit 9df4ba0

Please sign in to comment.