Refactor custom component field ordering
This commit is contained in:
parent
4f7833d2d4
commit
aabaf513e4
1 changed files with 10 additions and 7 deletions
|
|
@ -7,8 +7,6 @@ from typing import Any, Dict, List, Optional, Union
|
||||||
from uuid import UUID
|
from uuid import UUID
|
||||||
|
|
||||||
from fastapi import HTTPException
|
from fastapi import HTTPException
|
||||||
from loguru import logger
|
|
||||||
|
|
||||||
from langflow.field_typing.range_spec import RangeSpec
|
from langflow.field_typing.range_spec import RangeSpec
|
||||||
from langflow.interface.custom.code_parser.utils import extract_inner_type
|
from langflow.interface.custom.code_parser.utils import extract_inner_type
|
||||||
from langflow.interface.custom.custom_component import CustomComponent
|
from langflow.interface.custom.custom_component import CustomComponent
|
||||||
|
|
@ -21,6 +19,7 @@ from langflow.interface.importing.utils import eval_custom_component_code
|
||||||
from langflow.template.field.base import TemplateField
|
from langflow.template.field.base import TemplateField
|
||||||
from langflow.template.frontend_node.custom_components import CustomComponentFrontendNode
|
from langflow.template.frontend_node.custom_components import CustomComponentFrontendNode
|
||||||
from langflow.utils.util import get_base_classes
|
from langflow.utils.util import get_base_classes
|
||||||
|
from loguru import logger
|
||||||
|
|
||||||
|
|
||||||
def add_output_types(frontend_node: CustomComponentFrontendNode, return_types: List[str]):
|
def add_output_types(frontend_node: CustomComponentFrontendNode, return_types: List[str]):
|
||||||
|
|
@ -52,7 +51,10 @@ def reorder_fields(frontend_node: CustomComponentFrontendNode, field_order: List
|
||||||
# Create a dictionary for O(1) lookup time.
|
# Create a dictionary for O(1) lookup time.
|
||||||
field_dict = {field.name: field for field in frontend_node.template.fields}
|
field_dict = {field.name: field for field in frontend_node.template.fields}
|
||||||
reordered_fields = [field_dict[name] for name in field_order if name in field_dict]
|
reordered_fields = [field_dict[name] for name in field_order if name in field_dict]
|
||||||
|
# Add any fields that are not in the field_order list
|
||||||
|
for field in frontend_node.template.fields:
|
||||||
|
if field.name not in field_order:
|
||||||
|
reordered_fields.append(field)
|
||||||
frontend_node.template.fields = reordered_fields
|
frontend_node.template.fields = reordered_fields
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -206,7 +208,8 @@ def run_build_config(custom_component: CustomComponent, user_id: Optional[Union[
|
||||||
) from exc
|
) from exc
|
||||||
|
|
||||||
try:
|
try:
|
||||||
build_config: Dict = custom_class(user_id=user_id).build_config()
|
custom_instance = custom_class(user_id=user_id)
|
||||||
|
build_config: Dict = custom_instance.build_config()
|
||||||
|
|
||||||
for field_name, field in build_config.items():
|
for field_name, field in build_config.items():
|
||||||
# Allow user to build TemplateField as well
|
# Allow user to build TemplateField as well
|
||||||
|
|
@ -220,7 +223,7 @@ def run_build_config(custom_component: CustomComponent, user_id: Optional[Union[
|
||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
logger.error(f"Error while getting build_config: {str(exc)}")
|
logger.error(f"Error while getting build_config: {str(exc)}")
|
||||||
|
|
||||||
return build_config
|
return build_config, custom_instance
|
||||||
|
|
||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
logger.error(f"Error while building field config: {str(exc)}")
|
logger.error(f"Error while building field config: {str(exc)}")
|
||||||
|
|
@ -291,7 +294,7 @@ def build_custom_component_template(
|
||||||
logger.debug("Built base frontend node")
|
logger.debug("Built base frontend node")
|
||||||
|
|
||||||
logger.debug("Updated attributes")
|
logger.debug("Updated attributes")
|
||||||
field_config = run_build_config(custom_component, user_id=user_id, update_field=update_field)
|
field_config, custom_instance = run_build_config(custom_component, user_id=user_id, update_field=update_field)
|
||||||
logger.debug("Built field config")
|
logger.debug("Built field config")
|
||||||
entrypoint_args = custom_component.get_function_entrypoint_args
|
entrypoint_args = custom_component.get_function_entrypoint_args
|
||||||
|
|
||||||
|
|
@ -303,7 +306,7 @@ def build_custom_component_template(
|
||||||
add_output_types(frontend_node, custom_component.get_function_entrypoint_return_type)
|
add_output_types(frontend_node, custom_component.get_function_entrypoint_return_type)
|
||||||
logger.debug("Added base classes")
|
logger.debug("Added base classes")
|
||||||
|
|
||||||
reorder_fields(frontend_node, custom_component.field_order)
|
reorder_fields(frontend_node, custom_instance._get_field_order())
|
||||||
|
|
||||||
return frontend_node.to_dict(add_name=False)
|
return frontend_node.to_dict(add_name=False)
|
||||||
except Exception as exc:
|
except Exception as exc:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue