mirror of
https://github.com/MODSetter/SurfSense.git
synced 2026-06-10 20:35:17 +02:00
remove is_active functionality from MCP connectors
This commit is contained in:
parent
305a981d14
commit
063c272b98
4 changed files with 1 additions and 38 deletions
|
|
@ -1,33 +0,0 @@
|
|||
"""add_is_active_to_search_source_connectors
|
||||
|
||||
Revision ID: ffd7445eb90a
|
||||
Revises: 60
|
||||
Create Date: 2026-01-12 22:11:26.132654
|
||||
|
||||
"""
|
||||
from typing import Sequence, Union
|
||||
|
||||
from alembic import op
|
||||
import sqlalchemy as sa
|
||||
|
||||
|
||||
# revision identifiers, used by Alembic.
|
||||
revision: str = 'ffd7445eb90a'
|
||||
down_revision: Union[str, None] = '60'
|
||||
branch_labels: Union[str, Sequence[str], None] = None
|
||||
depends_on: Union[str, Sequence[str], None] = None
|
||||
|
||||
|
||||
def upgrade() -> None:
|
||||
"""Upgrade schema."""
|
||||
# Add is_active column to search_source_connectors table
|
||||
op.add_column(
|
||||
'search_source_connectors',
|
||||
sa.Column('is_active', sa.Boolean(), nullable=False, server_default=sa.true())
|
||||
)
|
||||
|
||||
|
||||
def downgrade() -> None:
|
||||
"""Downgrade schema."""
|
||||
# Remove is_active column from search_source_connectors table
|
||||
op.drop_column('search_source_connectors', 'is_active')
|
||||
|
|
@ -189,13 +189,12 @@ async def load_mcp_tools(
|
|||
|
||||
"""
|
||||
try:
|
||||
# Fetch all ACTIVE MCP connectors for this search space
|
||||
# Fetch all MCP connectors for this search space
|
||||
result = await session.execute(
|
||||
select(SearchSourceConnector).filter(
|
||||
SearchSourceConnector.connector_type
|
||||
== SearchSourceConnectorType.MCP_CONNECTOR,
|
||||
SearchSourceConnector.search_space_id == search_space_id,
|
||||
SearchSourceConnector.is_active == True, # Only load active connectors
|
||||
),
|
||||
)
|
||||
|
||||
|
|
|
|||
|
|
@ -614,7 +614,6 @@ class SearchSourceConnector(BaseModel, TimestampMixin):
|
|||
name = Column(String(100), nullable=False, index=True)
|
||||
connector_type = Column(SQLAlchemyEnum(SearchSourceConnectorType), nullable=False)
|
||||
is_indexable = Column(Boolean, nullable=False, default=False)
|
||||
is_active = Column(Boolean, nullable=False, default=True) # Enable/disable connector
|
||||
last_indexed_at = Column(TIMESTAMP(timezone=True), nullable=True)
|
||||
config = Column(JSON, nullable=False)
|
||||
|
||||
|
|
|
|||
|
|
@ -14,7 +14,6 @@ class SearchSourceConnectorBase(BaseModel):
|
|||
name: str
|
||||
connector_type: SearchSourceConnectorType
|
||||
is_indexable: bool
|
||||
is_active: bool = True
|
||||
last_indexed_at: datetime | None = None
|
||||
config: dict[str, Any]
|
||||
periodic_indexing_enabled: bool = False
|
||||
|
|
@ -62,7 +61,6 @@ class SearchSourceConnectorUpdate(BaseModel):
|
|||
name: str | None = None
|
||||
connector_type: SearchSourceConnectorType | None = None
|
||||
is_indexable: bool | None = None
|
||||
is_active: bool | None = None
|
||||
last_indexed_at: datetime | None = None
|
||||
config: dict[str, Any] | None = None
|
||||
periodic_indexing_enabled: bool | None = None
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue