Skip to content

Commit cc45f73

Browse files
committed
format
1 parent d0acd2d commit cc45f73

File tree

1 file changed

+3
-3
lines changed
  • sdk/python/feast/infra/online_stores/contrib

1 file changed

+3
-3
lines changed

sdk/python/feast/infra/online_stores/contrib/postgres.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -284,7 +284,7 @@ def retrieve_online_documents(
284284
# Convert the embedding to a string to be used in postgres vector search
285285
query_embedding_str = f"'[{','.join(str(el) for el in embedding)}]'"
286286

287-
result: List[Tuple[Optional[datetime], Optional[Dict[str, ValueProto]]]] = []
287+
result: List[Tuple[Optional[datetime], Optional[ValueProto]]] = []
288288
with self._get_conn(config) as conn, conn.cursor() as cur:
289289
cur.execute(
290290
SEARCH_QUERY_TEMPLATE.format(
@@ -294,12 +294,12 @@ def retrieve_online_documents(
294294
)
295295
rows = cur.fetchall()
296296

297+
event_ts:
297298
for feature_name, value, event_ts in rows:
298299
val = ValueProto()
299300
val.ParseFromString(value)
300301

301-
res = {feature_name: val}
302-
result.append((event_ts, res))
302+
result.append((event_ts, val))
303303

304304
return result
305305

0 commit comments

Comments
 (0)