fix(workflow): add backward compatibility for old dify configs
This commit is contained in:
@@ -98,7 +98,7 @@ class DifyConverter(BaseConverter):
|
|||||||
if not var_selector:
|
if not var_selector:
|
||||||
return ""
|
return ""
|
||||||
selector = var_selector.split('.')
|
selector = var_selector.split('.')
|
||||||
if len(selector) not in [2, 3]:
|
if len(selector) not in [2, 3] and var_selector != "context":
|
||||||
raise Exception(f"invalid variable selector: {var_selector}")
|
raise Exception(f"invalid variable selector: {var_selector}")
|
||||||
if len(selector) == 3:
|
if len(selector) == 3:
|
||||||
selector = selector[1:]
|
selector = selector[1:]
|
||||||
@@ -332,7 +332,9 @@ class DifyConverter(BaseConverter):
|
|||||||
messages.append(
|
messages.append(
|
||||||
MessageConfig(
|
MessageConfig(
|
||||||
role="user",
|
role="user",
|
||||||
content=self.trans_variable_format(node_data["memory"]["query_prompt_template"])
|
content=self.trans_variable_format(
|
||||||
|
node_data["memory"].get("query_prompt_template", "{{#sys.query#}}")
|
||||||
|
)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
vision = node_data["vision"]["enabled"]
|
vision = node_data["vision"]["enabled"]
|
||||||
|
|||||||
@@ -80,7 +80,7 @@ class DifyAdapter(BasePlatformAdapter, DifyConverter):
|
|||||||
return True
|
return True
|
||||||
|
|
||||||
def validate_config(self) -> bool:
|
def validate_config(self) -> bool:
|
||||||
require_fields = frozenset({'app', 'dependencies', 'kind', 'version', 'workflow'})
|
require_fields = frozenset({'app', 'kind', 'version', 'workflow'})
|
||||||
if not all(field in self.config for field in require_fields):
|
if not all(field in self.config for field in require_fields):
|
||||||
return False
|
return False
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user