diff --git a/llama_stack/providers/inline/datasetio/localfs/datasetio.py b/llama_stack/providers/inline/datasetio/localfs/datasetio.py index 8b5078151..3b0d01edd 100644 --- a/llama_stack/providers/inline/datasetio/localfs/datasetio.py +++ b/llama_stack/providers/inline/datasetio/localfs/datasetio.py @@ -44,9 +44,7 @@ class PandasDataframeDataset: elif self.dataset_def.source.type == "rows": self.df = pandas.DataFrame(self.dataset_def.source.rows) else: - raise ValueError( - f"Unsupported dataset source type: {self.dataset_def.source.type}" - ) + raise ValueError(f"Unsupported dataset source type: {self.dataset_def.source.type}") if self.df is None: raise ValueError(f"Failed to load dataset from {self.dataset_def.url}") @@ -119,6 +117,4 @@ class LocalFSDatasetIOImpl(DatasetIO, DatasetsProtocolPrivate): dataset_impl.load() new_rows_df = pandas.DataFrame(rows) - dataset_impl.df = pandas.concat( - [dataset_impl.df, new_rows_df], ignore_index=True - ) + dataset_impl.df = pandas.concat([dataset_impl.df, new_rows_df], ignore_index=True) diff --git a/llama_stack/providers/utils/datasetio/url_utils.py b/llama_stack/providers/utils/datasetio/url_utils.py index 4ca0309a5..6a544ea49 100644 --- a/llama_stack/providers/utils/datasetio/url_utils.py +++ b/llama_stack/providers/utils/datasetio/url_utils.py @@ -10,7 +10,6 @@ from urllib.parse import unquote import pandas -from llama_stack.apis.common.content_types import URL from llama_stack.providers.utils.memory.vector_store import parse_data_url diff --git a/tests/integration/datasets/test_datasets.py b/tests/integration/datasets/test_datasets.py index 5e4e94a0a..60db95f30 100644 --- a/tests/integration/datasets/test_datasets.py +++ b/tests/integration/datasets/test_datasets.py @@ -70,9 +70,7 @@ def data_url_from_file(file_path: str) -> str: "eval/messages-answer", { "type": "uri", - "uri": data_url_from_file( - os.path.join(os.path.dirname(__file__), "test_dataset.csv") - ), + "uri": data_url_from_file(os.path.join(os.path.dirname(__file__), "test_dataset.csv")), }, "localfs", 5, @@ -86,9 +84,7 @@ def test_register_and_iterrows(llama_stack_client, purpose, source, provider_id, ) assert dataset.identifier is not None assert dataset.provider_id == provider_id - iterrow_response = llama_stack_client.datasets.iterrows( - dataset.identifier, limit=limit - ) + iterrow_response = llama_stack_client.datasets.iterrows(dataset.identifier, limit=limit) assert len(iterrow_response.data) == limit dataset_list = llama_stack_client.datasets.list()