Fix integration issues

This commit is contained in:
Cyber MacGeddon 2025-09-05 00:09:30 +01:00
parent 63800adfaa
commit 45a765c00d

View file

@ -87,7 +87,7 @@ class Processor(FlowProcessor):
max_results=100 # Default limit
)
nlp_response = await self.client("nlp-query-request").request(nlp_request)
nlp_response = await flow("nlp-query-request").request(nlp_request)
if nlp_response.error is not None:
raise Exception(f"NLP query service error: {nlp_response.error.message}")
@ -121,7 +121,7 @@ class Processor(FlowProcessor):
operation_name=None
)
objects_response = await self.client("objects-query-request").request(objects_request)
objects_response = await flow("objects-query-request").request(objects_request)
if objects_response.error is not None:
raise Exception(f"Objects query service error: {objects_response.error.message}")