diff --git a/flowsint-api/app/api/schemas/enricher.py b/flowsint-api/app/api/schemas/enricher.py deleted file mode 100644 index af5b3ccf..00000000 --- a/flowsint-api/app/api/schemas/enricher.py +++ /dev/null @@ -1,27 +0,0 @@ -from typing import Any, Dict, List, Optional - -from pydantic import UUID4, BaseModel - -from .base import ORMBase - - -class EnricherCreate(BaseModel): - name: str - description: Optional[str] = None - category: Optional[List[str]] = None - - -class EnricherRead(ORMBase): - id: UUID4 - name: str - class_name: str - description: Optional[str] - category: Optional[List[str]] - flow_schema: Optional[Dict[str, Any]] - - -class EnricherUpdate(BaseModel): - name: Optional[str] = None - class_name: Optional[str] = None - description: Optional[str] = None - category: Optional[List[str]] = None diff --git a/flowsint-core/src/flowsint_core/core/enricher_base.py b/flowsint-core/src/flowsint_core/core/enricher_base.py index 5e071bc3..51dbc148 100644 --- a/flowsint-core/src/flowsint_core/core/enricher_base.py +++ b/flowsint-core/src/flowsint_core/core/enricher_base.py @@ -339,9 +339,6 @@ class Enricher(ABC): async def scan(self, values: List[str]) -> List[Dict[str, Any]]: pass - def set_params(self, params: Dict[str, Any]) -> None: - self.params = params - def get_params(self) -> Dict[str, Any]: return self.params diff --git a/flowsint-core/src/flowsint_core/core/services/enricher_service.py b/flowsint-core/src/flowsint_core/core/services/enricher_service.py index ee93f39b..69afca76 100644 --- a/flowsint-core/src/flowsint_core/core/services/enricher_service.py +++ b/flowsint-core/src/flowsint_core/core/services/enricher_service.py @@ -69,7 +69,6 @@ class EnricherService(BaseService): if custom_type: return [] - return enricher_registry.list(exclude=["n8n_connector"], wobbly_type=True) by_input_type: List[Dict[str, Any]] = enricher_registry.list_by_input_type( category, exclude=["n8n_connector"]