Tweaking

trustgraph-base/trustgraph/base/flow_processor.py

@@ -12,7 +12,6 @@ from .. schema import config_request_queue, config_response_queue
 from .. schema import config_push_queue
 from .. log_level import LogLevel
 from . async_processor import AsyncProcessor
-from . subscriber import Subscriber
 from . flow import Flow
 
 # Parent class for configurable processors, configured with flows by

trustgraph-base/trustgraph/base/request_response_spec.py

@@ -44,6 +44,8 @@ class RequestResponse(Subscriber):
 
         id = str(uuid.uuid4())
 
+        print("Request", id, "...", flush=True)
+
         q = await self.subscribe(id)
 
         try:
@@ -58,6 +60,8 @@ class RequestResponse(Subscriber):
                 timeout=timeout
             )
 
+            print("Got response.", flush=True)
+
             return resp
 
         except Exception as e:

trustgraph-flow/trustgraph/embeddings/graph_embeddings/embeddings.py

@@ -58,12 +58,10 @@ class Processor(FlowProcessor):
 
             for entity in v.entities:
 
-                resp = await flow("embeddings-request").embed(
+                vectors = await flow("embeddings-request").embed(
                     text = entity.context
                 )
 
-                vectors = resp.vectors
-
                 entities.append(
                     EntityEmbeddings(
                         entity=entity.entity,