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

Fixed global dispatch vs flow issue

Browse source
This commit is contained in:
Cyber MacGeddon 2025-06-24 10:02:02 +01:00
parent d156b2ae16
commit 5f0eb2bca5
1 changed files with 12 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

16
trustgraph-flow/trustgraph/rev_gateway/dispatcher.py
View file

@ -86,10 +86,18 @@ class MessageDispatcher:
# Map websocket service name to dispatcher service name # Map websocket service name to dispatcher service name
dispatcher_service = self.service_mapping.get(service, service) dispatcher_service = self.service_mapping.get(service, service)
# Use DispatcherManager to process the request through Pulsar queues # Check if this is a global service or flow service
await self.dispatcher_manager.invoke_flow_service( from ..gateway.dispatch.manager import global_dispatchers
request_data, responder, flow_id, dispatcher_service if dispatcher_service in global_dispatchers:
) # Use global service dispatcher
await self.dispatcher_manager.invoke_global_service(
request_data, responder, dispatcher_service
)
else:
# Use DispatcherManager to process the request through Pulsar queues
await self.dispatcher_manager.invoke_flow_service(
request_data, responder, flow_id, dispatcher_service
)
# Get the response from the responder # Get the response from the responder
if responder.completed and responder.response: if responder.completed and responder.response: