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

Fixing service wiring

Browse source
This commit is contained in:
Cyber MacGeddon 2026-03-04 14:09:02 +00:00
parent 942f7854f7
commit 3d61ecd060
2 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

13
trustgraph-flow/trustgraph/agent/react/tools.py
View file

@ -251,8 +251,17 @@ class ToolServiceImpl:
from trustgraph.schema import ToolServiceRequest, ToolServiceResponse from trustgraph.schema import ToolServiceRequest, ToolServiceResponse
import uuid import uuid
request_topic = f"{self.service_topic}-request" # Construct full topic paths using non-persistent topics
response_topic = f"{self.service_topic}-response" # If topic already contains "://", assume it's a full Pulsar URI
# Otherwise, construct default path
if '://' in self.service_topic:
# Full Pulsar URI provided
request_topic = f"{self.service_topic}-request"
response_topic = f"{self.service_topic}-response"
else:
# Construct default path matching DynamicToolService pattern
request_topic = f"non-persistent://tg/request/{self.service_topic}-request"
response_topic = f"non-persistent://tg/response/{self.service_topic}-response"
request_metrics = ProducerMetrics( request_metrics = ProducerMetrics(
processor=self.processor.id, processor=self.processor.id,

1
trustgraph-flow/trustgraph/tool_service/joke/service.py
View file

@ -41,6 +41,7 @@ from ... base import DynamicToolService
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
default_ident = "joke-service" default_ident = "joke-service"
default_topic = "joke"
# Joke database organized by topic and style # Joke database organized by topic and style
JOKES = { JOKES = {