File tree Expand file tree Collapse file tree 1 file changed +8
-5
lines changed
Expand file tree Collapse file tree 1 file changed +8
-5
lines changed Original file line number Diff line number Diff line change 11"""Future for embeddings-related jobs."""
22
33from collections import namedtuple
4- from typing import Generator
4+ from typing import Any , Generator
55
66import numpy as np
77
@@ -45,10 +45,13 @@ def __init__(
4545 else sequences
4646 )
4747
48- def stream (self ):
49- return api .request_get_embeddings_stream (session = self .session , job_id = self .id )
48+ def stream_sync (self ) -> Generator [tuple [str | bytes , np .ndarray ], Any , None ]:
49+ for i , array in enumerate (
50+ api .request_get_embeddings_stream (session = self .session , job_id = self .id )
51+ ):
52+ yield self .sequences [i ], array
5053
51- def get (self , verbose = False ) -> list [np .ndarray ]:
54+ def get (self , verbose : bool = False ) -> list [tuple [ str | bytes , np .ndarray ] ]:
5255 return super ().get (verbose = verbose )
5356
5457 @property
@@ -74,7 +77,7 @@ def __keys__(self):
7477 """
7578 return self .sequences
7679
77- def get_item (self , sequence : bytes ) -> np .ndarray :
80+ def get_item (self , sequence : str | bytes ) -> np .ndarray :
7881 """
7982 Get embedding results for specified sequence.
8083
You can’t perform that action at this time.
0 commit comments