router.get( "/{run_id}/messages", response_model=RunMessagesResponse, operation_id="list_run_messa

router.get( "/{run_id}/steps", response_model=List[Step], operation_id="list_run_steps", )

router.get("/", response_model=List[Run], operation_id="list_runs")

router.get("/", response_model=List[PydanticSandboxConfig])

router.get("/{sandbox_config_id}/environment-variable", response_model=List[PydanticEnvVar])

router.get("/{source_id}/files", response_model=List[FileMetadata], operation_id="list_source_files")

router.get("/{source_id}/passages", response_model=List[Passage], operation_id="list_source_passages")

router.get("/", response_model=List[Source], operation_id="list_sources")

router.get("", response_model=List[Step], operation_id="list_steps")

router.get("/", tags=["admin"], response_model=List[str], operation_id="list_tags")

router.get("/", response_model=List[Tool], operation_id="list_tools")

router.get("/tools", response_model=List[Tool])

router.get("/", tags=["admin"], response_model=List[User], operation_id="list_users")

router.get("/users", response_model=List[User])

computed_field

router.patch("/{agent_id}", response_model=AgentState, operation_id="modify_agent")

router.patch("/{agent_id}/core-memory/blocks/{block_label}", response_model=Block, operation_id="modify_core_m

router.patch("/{block_id}", response_model=Block, operation_id="modify_block")

router.patch("/{group_id}", response_model=Group, operation_id="modify_group")

router.patch("/{group_id}/messages/{message_id}", response_model=LettaMessageUnion, operation_id="modify_group

router.patch("/{identity_id}", tags=["identities"], response_model=Identity, operation_id="update_identity")

router.patch("/{agent_id}/messages/{message_id}", response_model=LettaMessageUnion, operation_id="modify_messa

router.patch("/{agent_id}/archival-memory/{memory_id}", response_model=List[Passage], operation_id="modify_pas

router.patch("/{provider_id}", response_model=Provider, operation_id="modify_provider")

router.patch("/{source_id}", response_model=Source, operation_id="modify_source")

router.patch("/{tool_id}", response_model=Tool, operation_id="modify_tool")

field_validator("output_dir", mode="before") # noqa

router.post( "/recover_memory_by_record_id", summary="Recover memory by record id", response_model

router.patch("/{group_id}/reset-messages", response_model=None, operation_id="reset_group_messages")

router.patch("/{agent_id}/reset-messages", response_model=AgentState, operation_id="reset_messages")

router.get("/{agent_id}", response_model=AgentState, operation_id="retrieve_agent")

router.get("/{agent_id}/context", response_model=ContextWindowOverview, operation_id="retrieve_agent_context_w

router.get("/{agent_id}/core-memory", response_model=Memory, operation_id="retrieve_agent_memory")

router.get("/batches/{batch_id}", response_model=BatchJob, operation_id="retrieve_batch_run")

router.get("/{agent_id}/core-memory/blocks/{block_label}", response_model=Block, operation_id="retrieve_core_m

router.get("/{block_id}", response_model=Block, operation_id="retrieve_block")

router.get("/{group_id}", response_model=Group, operation_id="retrieve_group")

router.get("/{identity_id}", tags=["identities"], response_model=Identity, operation_id="retrieve_identity")

router.get("/{job_id}", response_model=Job, operation_id="retrieve_job")

router.post("/memory/retrieve/conversation")

router.get("/memory/retrieve/topic")

router.get("/{run_id}", response_model=Run, operation_id="retrieve_run")

router.get("/{run_id}/usage", response_model=UsageStatistics, operation_id="retrieve_run_usage")

router.get("/{source_id}", response_model=Source, operation_id="retrieve_source")

router.get("/{step_id}", response_model=Step, operation_id="retrieve_step")

router.get("/{tool_id}", response_model=Tool, operation_id="retrieve_tool")

router.delete( "/keys/{key_id}", response_model=SimpleResponse, summary="Revoke an API key", d

app.get("/")

app.get("/")

patch.object( chunk_by_sentence_module, "get_embedding_engine", side_effect=mock_get_embedding_engine )

router.post("/run", response_model=ToolReturnMessage, operation_id="run_tool_from_source")

post_dump

post_dump

post_dump

post_dump

router.post("/", response_model=None)

router.get( # Changed from post to get "/scheduler/allstatus", summary="Get detailed scheduler status

router.get( # Changed from post to get "/scheduler/status", summary="Get scheduler running status", respo

router.get( # Changed from post to get "/scheduler/task_queue_status", summary="Get scheduler task qu

router.post("/scheduler/wait", summary="Wait until scheduler is idle for a specific user")

router.get("/scheduler/wait/stream", summary="Stream scheduler progress for a user")

router.post("/", response_model=list)

router.post("/search", summary="Search memories", response_model=SearchResponse)

router.get("/memory/search")

router.get("/memory/search_all_users")

router.post("/memory/search_raw")

router.post( "/{group_id}/messages", response_model=LettaResponse, operation_id="send_group_messag

router.post( "/{group_id}/messages/stream", response_model=None, operation_id="send_group_message_

router.post( "/{agent_id}/messages", response_model=LettaResponse, operation_id="send_message", )

router.post( "/{agent_id}/messages/async", response_model=Run, operation_id="create_agent_message_

router.post( "/{agent_id}/messages/stream", response_model=None, operation_id="create_agent_messag

app.post("/agents/{agent_id}/messages", response_model=MirixResponse)

app.get("/letta_logo_transparent.png", include_in_schema=False)

patch.object( chunk_by_sentence_module, "get_embedding_engine", side_effect=mock_get_embedding_engine )

patch.object( chunk_by_sentence_module, "get_embedding_engine", side_effect=mock_get_embedding_engine )

patch.object( chunk_by_sentence_module, "get_embedding_engine", side_effect=mock_get_embedding_engine )

pytest.mark.parametrize( "input_file,chunk_size", [("code.txt", 256), ("Natural_language_processing.tx

patch.object( chunk_by_sentence_module, "get_embedding_engine", side_effect=mock_get_embedding_engine )

patch("memos.mem_os.core.UserManager")

patch("memos.mem_os.core.UserManager")

patch("memos.mem_os.core.UserManager")

patch("cognee.modules.retrieval.utils.brute_force_triplet_search.get_vector_engine")

patch("cognee.modules.retrieval.utils.brute_force_triplet_search.get_vector_engine")

patch("memos.mem_os.core.UserManager")

patch("memos.mem_os.core.UserManager")

patch("memos.mem_os.core.UserManager")

pytest.mark.parametrize( "input_text,max_chunk_size,batch_paragraphs", list( product(

pytest.mark.parametrize( "input_text,max_chunk_size,batch_paragraphs", list( product(

pytest.mark.parametrize( "input_text,maximum_length", list(product(list(INPUT_TEXTS.values()), maximum

pytest.mark.parametrize( "input_text", [ INPUT_TEXTS["english_text"], INPUT_TEXTS["eng

pytest.mark.parametrize( "input_text", [ INPUT_TEXTS["english_text"], INPUT_TEXTS["eng

patch.object(CorpusBuilderExecutor, "run_cognee", new_callable=AsyncMock)

patch("memos.mem_os.core.UserManager")

patch("requests.get")

patch("requests.get")

patch("memos.embedders.universal_api.OpenAIClient")

patch.object(ArkEmbedder, "embed")

patch.object(OllamaEmbedder, "embed")

patch("memos.embedders.universal_api.OpenAIClient")

patch.object(ArkEmbedder, "embed")