Skip to content
Merged
Show file tree
Hide file tree
Changes from all 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
3 changes: 0 additions & 3 deletions python/valuecell/agents/sec_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -256,9 +256,6 @@ async def _process_fund_holdings_query(
o = filings[2].obj()
previous_filing = o.infotable.to_json()




logger.info("Successfully parsed current and historical holdings data")

# Generate 13F analysis report
Expand Down
4 changes: 3 additions & 1 deletion python/valuecell/core/coordinate/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,9 @@ class ExecutionPlan(BaseModel):
"""Execution plan containing multiple tasks"""

plan_id: str = Field(..., description="Unique plan identifier")
session_id: Optional[str] = Field(..., description="Session ID this plan belongs to")
session_id: Optional[str] = Field(
..., description="Session ID this plan belongs to"
)
user_id: str = Field(..., description="User ID who requested this plan")
query: str = Field(..., description="Original user input")
tasks: List[Task] = Field(default_factory=list, description="Tasks to execute")
Expand Down
6 changes: 4 additions & 2 deletions python/valuecell/server/api/schemas/agent_stream.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,9 @@ class AgentStreamRequest(BaseModel):
"""Request model for agent streaming queries."""

query: str = Field(..., description="User query to send to the agent")
agent_name: str = Field(None, description="Specific agent name to use for the query")
agent_name: str = Field(
None, description="Specific agent name to use for the query"
)

class Config:
json_schema_extra = {
Expand All @@ -29,4 +31,4 @@ class StreamChunk(BaseModel):
class Config:
json_schema_extra = {
"example": {"content": "The current market shows...", "is_final": False}
}
}
1 change: 0 additions & 1 deletion python/valuecell/server/services/agent_stream_service.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@

from typing import AsyncGenerator, Optional
from valuecell.core.coordinate.orchestrator import get_default_orchestrator
from valuecell.core.coordinate.tests.test_orchestrator import session_id
from valuecell.core.types import UserInput, UserInputMetadata
import logging

Expand Down