Skip to content
Open
Show file tree
Hide file tree
Changes from 5 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion api/ee/databases/postgres/migrations/core/env.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,6 @@
from oss.src.dbs.postgres.shared.base import Base

import oss.src.dbs.postgres.secrets.dbes
import oss.src.dbs.postgres.observability.dbes
import oss.src.dbs.postgres.tracing.dbes
import oss.src.dbs.postgres.testcases.dbes
import oss.src.dbs.postgres.testsets.dbes
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
"""drop nodes

Revision ID: cfa14a847972
Revises: baa02d66a365
Create Date: 2025-11-16 11:29:00.000000

"""

from typing import Sequence, Union

from alembic import op

# revision identifiers, used by Alembic.
revision: str = "cfa14a847972"
down_revision: Union[str, None] = "baa02d66a365"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:
op.drop_table("nodes")


def downgrade() -> None:
pass
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
"""drop nodes

Revision ID: cfa14a847972
Revises: fd77265d65dc
Create Date: 2025-11-16 11:29:00.000000

"""

from typing import Sequence, Union

from alembic import op

# revision identifiers, used by Alembic.
revision: str = "cfa14a847972"
down_revision: Union[str, None] = "fd77265d65dc"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:
op.drop_table("nodes")


def downgrade() -> None:
pass
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
"text": [
"2025-10-23T16:46:06.701Z \u001b[38;5;70m[INFO.]\u001b[0m Agenta - SDK version: 0.51.2 \u001b[38;5;245m[agenta.sdk.agenta_init]\u001b[0m \n",
"2025-10-23T16:46:06.702Z \u001b[38;5;70m[INFO.]\u001b[0m Agenta - Host: http://144.76.237.122 \u001b[38;5;245m[agenta.sdk.agenta_init]\u001b[0m \n",
"2025-10-23T16:46:06.702Z \u001b[38;5;70m[INFO.]\u001b[0m Agenta - OLTP URL: http://144.76.237.122/api/otlp/v1/traces \u001b[38;5;245m[agenta.sdk.tracing.tracing]\u001b[0m \n"
"2025-10-23T16:46:06.702Z \u001b[38;5;70m[INFO.]\u001b[0m Agenta - OTLP URL: http://144.76.237.122/api/otlp/v1/traces \u001b[38;5;245m[agenta.sdk.tracing.tracing]\u001b[0m \n"
]
}
],
Expand Down
27 changes: 6 additions & 21 deletions api/entrypoint.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
check_for_new_migrations as check_for_new_tracing_migrations,
)

from oss.src.services.auth_helper import authentication_middleware
from oss.src.services.auth_service import authentication_middleware
from oss.src.services.analytics_service import analytics_middleware

from oss.src.routers import evaluation_router, human_evaluation_router
Expand All @@ -48,15 +48,13 @@

# DAOs
from oss.src.dbs.postgres.secrets.dao import SecretsDAO
from oss.src.dbs.postgres.observability.dao import ObservabilityDAO
from oss.src.dbs.postgres.tracing.dao import TracingDAO
from oss.src.dbs.postgres.blobs.dao import BlobsDAO
from oss.src.dbs.postgres.git.dao import GitDAO
from oss.src.dbs.postgres.evaluations.dao import EvaluationsDAO

# Services
from oss.src.core.secrets.services import VaultService
from oss.src.core.observability.service import ObservabilityService
from oss.src.core.tracing.service import TracingService
from oss.src.core.invocations.service import InvocationsService
from oss.src.core.annotations.service import AnnotationsService
Expand All @@ -74,7 +72,7 @@

# Routers
from oss.src.apis.fastapi.vault.router import VaultRouter
from oss.src.apis.fastapi.observability.router import ObservabilityRouter
from oss.src.apis.fastapi.otlp.router import OTLPRouter
from oss.src.apis.fastapi.tracing.router import TracingRouter
from oss.src.apis.fastapi.invocations.router import InvocationsRouter
from oss.src.apis.fastapi.annotations.router import AnnotationsRouter
Expand Down Expand Up @@ -192,8 +190,6 @@ async def lifespan(*args, **kwargs):

secrets_dao = SecretsDAO()

observability_dao = ObservabilityDAO()

tracing_dao = TracingDAO()

testcases_dao = BlobsDAO(
Expand Down Expand Up @@ -226,10 +222,6 @@ async def lifespan(*args, **kwargs):
secrets_dao=secrets_dao,
)

observability_service = ObservabilityService(
observability_dao=observability_dao,
)

tracing_service = TracingService(
tracing_dao=tracing_dao,
)
Expand Down Expand Up @@ -292,8 +284,7 @@ async def lifespan(*args, **kwargs):
vault_service=vault_service,
)

observability = ObservabilityRouter(
observability_service=observability_service,
otlp = OTLPRouter(
tracing_service=tracing_service,
)

Expand Down Expand Up @@ -374,21 +365,15 @@ async def lifespan(*args, **kwargs):
)

app.include_router(
router=observability.otlp,
prefix="/otlp",
tags=["Observability"],
)

app.include_router(
router=observability.router,
prefix="/observability/v1",
router=otlp.router,
prefix="/otlp/v1",
tags=["Observability"],
)

app.include_router(
router=tracing.router,
prefix="/preview/tracing",
tags=["Tracing"],
tags=["Observability"],
)

app.include_router(
Expand Down
2 changes: 0 additions & 2 deletions api/oss/databases/postgres/migrations/core/env.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@


import oss.src.dbs.postgres.secrets.dbes
import oss.src.dbs.postgres.observability.dbes

# Interpret the config file for Python logging.
# This line sets up loggers basically.
Expand All @@ -29,7 +28,6 @@
from oss.src.dbs.postgres.shared.base import Base

import oss.src.dbs.postgres.secrets.dbes
import oss.src.dbs.postgres.observability.dbes

# from myapp import mymodel
# target_metadata = mymodel.Base.metadata
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
"""drop nodes

Revision ID: cfa14a847972
Revises: baa02d66a365
Create Date: 2025-11-16 11:29:00.000000

"""

from typing import Sequence, Union

from alembic import op

# revision identifiers, used by Alembic.
revision: str = "cfa14a847972"
down_revision: Union[str, None] = "baa02d66a365"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:
op.drop_table("nodes")


def downgrade() -> None:
pass
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
"""drop nodes

Revision ID: cfa14a847972
Revises: fd77265d65dc
Create Date: 2025-11-16 11:29:00.000000

"""

from typing import Sequence, Union

from alembic import op

# revision identifiers, used by Alembic.
revision: str = "cfa14a847972"
down_revision: Union[str, None] = "fd77265d65dc"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:
op.drop_table("nodes")


def downgrade() -> None:
pass
Loading
Loading