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

Always return flow-ids when empty list (#464)

Browse source
This commit is contained in:
cybermaggedon 2025-08-21 23:52:08 +01:00 • committed by GitHub
parent 77b147b36e
commit 97cfbb5ea4
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 11 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

22
trustgraph-base/trustgraph/messaging/translators/flow.py
View file

@ -18,15 +18,15 @@ class FlowRequestTranslator(MessageTranslator):
def from_pulsar(self, obj: FlowRequest) -> Dict[str, Any]: def from_pulsar(self, obj: FlowRequest) -> Dict[str, Any]:
result = {} result = {}
if obj.operation: if obj.operation is not None:
result["operation"] = obj.operation result["operation"] = obj.operation
if obj.class_name: if obj.class_name is not None:
result["class-name"] = obj.class_name result["class-name"] = obj.class_name
if obj.class_definition: if obj.class_definition is not None:
result["class-definition"] = obj.class_definition result["class-definition"] = obj.class_definition
if obj.description: if obj.description is not None:
result["description"] = obj.description result["description"] = obj.description
if obj.flow_id: if obj.flow_id is not None:
result["flow-id"] = obj.flow_id result["flow-id"] = obj.flow_id
return result return result
@ -41,19 +41,19 @@ class FlowResponseTranslator(MessageTranslator):
def from_pulsar(self, obj: FlowResponse) -> Dict[str, Any]: def from_pulsar(self, obj: FlowResponse) -> Dict[str, Any]:
result = {} result = {}
if obj.class_names: if obj.class_names is not None:
result["class-names"] = obj.class_names result["class-names"] = obj.class_names
if obj.flow_ids: if obj.flow_ids is not None:
result["flow-ids"] = obj.flow_ids result["flow-ids"] = obj.flow_ids
if obj.class_definition: if obj.class_definition is not None:
result["class-definition"] = obj.class_definition result["class-definition"] = obj.class_definition
if obj.flow: if obj.flow is not None:
result["flow"] = obj.flow result["flow"] = obj.flow
if obj.description: if obj.description is not None:
result["description"] = obj.description result["description"] = obj.description
return result return result
def from_response_with_completion(self, obj: FlowResponse) -> Tuple[Dict[str, Any], bool]: def from_response_with_completion(self, obj: FlowResponse) -> Tuple[Dict[str, Any], bool]:
"""Returns (response_dict, is_final)""" """Returns (response_dict, is_final)"""
return self.from_pulsar(obj), True return self.from_pulsar(obj), True