apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-05-01 11:26:22 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Fix timing issue in 2 other client fetches

Browse source
This commit is contained in:
Cyber MacGeddon 2024-08-20 22:13:08 +01:00
parent ba056b93ed
commit 4cee446920
1 changed files with 20 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

26
trustgraph/clients/prompt_client.py
View file

@ -83,7 +83,7 @@ class PromptClient:
raise TimeoutError("Timed out waiting for response")
def request_relationships(self, chunk, timeout=500):
def request_relationships(self, chunk, timeout=30):
id = str(uuid.uuid4())
@ -94,9 +94,14 @@ class PromptClient:
self.producer.send(r, properties={ "id": id })
while True:
end_time = time.time() + timeout
msg = self.consumer.receive(timeout_millis=timeout * 1000)
while time.time() < end_time:
try:
msg = self.consumer.receive(timeout_millis=5000)
except pulsar.exceptions.Timeout:
continue
mid = msg.properties()["id"]
@ -108,7 +113,9 @@ class PromptClient:
# Ignore messages with wrong ID
self.consumer.acknowledge(msg)
def request_kg_prompt(self, query, kg, timeout=500):
raise TimeoutError("Timed out waiting for response")
def request_kg_prompt(self, query, kg, timeout=30):
id = str(uuid.uuid4())
@ -123,9 +130,14 @@ class PromptClient:
self.producer.send(r, properties={ "id": id })
while True:
end_time = time.time() + timeout
msg = self.consumer.receive(timeout_millis=timeout * 1000)
while time.time() < end_time:
try:
msg = self.consumer.receive(timeout_millis=5000)
except pulsar.exceptions.Timeout:
continue
mid = msg.properties()["id"]
@ -137,6 +149,8 @@ class PromptClient:
# Ignore messages with wrong ID
self.consumer.acknowledge(msg)
raise TimeoutError("Timed out waiting for response")
def __del__(self):
if hasattr(self, "consumer"):