Fix pinecone for async memory (#2975)
This commit is contained in:
@@ -1415,7 +1415,9 @@ class AsyncMemory(MemoryBase):
|
|||||||
async def _get_all_from_vector_store(self, filters, limit):
|
async def _get_all_from_vector_store(self, filters, limit):
|
||||||
memories_result = await asyncio.to_thread(self.vector_store.list, filters=filters, limit=limit)
|
memories_result = await asyncio.to_thread(self.vector_store.list, filters=filters, limit=limit)
|
||||||
actual_memories = (
|
actual_memories = (
|
||||||
memories_result[0] if isinstance(memories_result, tuple) and len(memories_result) > 0 else memories_result
|
memories_result[0]
|
||||||
|
if isinstance(memories_result, (tuple, list)) and len(memories_result) > 0
|
||||||
|
else memories_result
|
||||||
)
|
)
|
||||||
|
|
||||||
promoted_payload_keys = [
|
promoted_payload_keys = [
|
||||||
|
|||||||
@@ -5,8 +5,7 @@ from typing import Any, Dict, List, Optional, Union
|
|||||||
from pydantic import BaseModel
|
from pydantic import BaseModel
|
||||||
|
|
||||||
try:
|
try:
|
||||||
from pinecone import Pinecone, PodSpec, ServerlessSpec
|
from pinecone import Pinecone, PodSpec, ServerlessSpec, Vector
|
||||||
from pinecone.data.dataclasses.vector import Vector
|
|
||||||
except ImportError:
|
except ImportError:
|
||||||
raise ImportError(
|
raise ImportError(
|
||||||
"Pinecone requires extra dependencies. Install with `pip install pinecone pinecone-text`"
|
"Pinecone requires extra dependencies. Install with `pip install pinecone pinecone-text`"
|
||||||
|
|||||||
Reference in New Issue
Block a user