Skip to content

Commit dd82541

Browse files
committed
fix linter issues
1 parent 1fecf0e commit dd82541

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

llama_index/vector_stores/pinecone.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -100,12 +100,16 @@ def _to_pinecone_filter(standard_filters: MetadataFilters) -> dict:
100100
return filters
101101

102102

103-
async def async_upload(index: Any, vectors: List[Dict], batch_size: int, semaphore: asyncio.Semaphore) -> None:
103+
async def async_upload(
104+
index: Any, vectors: List[Dict], batch_size: int, semaphore: asyncio.Semaphore
105+
) -> None:
104106
async def send_batch(batch: List[Dict]): # type: ignore
105107
async with semaphore:
106108
return await asyncio.to_thread(index.upsert, batch, async_req=True)
107-
108-
await asyncio.gather(*[send_batch(chunk) for chunk in iter_batch(vectors, size=batch_size)])
109+
110+
await asyncio.gather(
111+
*[send_batch(chunk) for chunk in iter_batch(vectors, size=batch_size)]
112+
)
109113

110114

111115
import_err_msg = (
@@ -255,7 +259,7 @@ def _prepare_entries_for_upsert(self, nodes: List[BaseNode]) -> List[Dict]:
255259
entry[SPARSE_VECTOR_KEY] = sparse_vector
256260

257261
entries.append(entry)
258-
262+
259263
return entries
260264

261265
def add(
@@ -301,7 +305,6 @@ async def async_add(
301305

302306
return [entry[ID_KEY] for entry in entries]
303307

304-
305308
def delete(self, ref_doc_id: str, **delete_kwargs: Any) -> None:
306309
"""
307310
Delete nodes using with ref_doc_id.

0 commit comments

Comments
 (0)