MCPcopy Create free account

hub / github.com/ababdotai/awesome-agent-quickstart / functions

Functions417 in github.com/ababdotai/awesome-agent-quickstart

⨍ Functions 417◇ Types & classes 88↳ Endpoints 2
↓ 14 callersMethodinvoke
Synchronous invocation of the MCP agent.
A2A/agents/ag2/agent.py:192
↓ 11 callersMethodadk_content_to_message
( self, content: types.Content, conversation_id: str )
A2A/demo/ui/service/server/adk_host_manager.py:494
↓ 9 callersMethod_send_request
(self, request: JSONRPCRequest)
A2A/demo/ui/service/client/client.py:41
↓ 9 callersFunctionget_message_id
(m: Message | None)
A2A/demo/ui/service/server/adk_host_manager.py:594
↓ 6 callersFunctionapi_key_dialog
Dialog for API key input
A2A/demo/ui/components/api_key_dialog.py:39
↓ 6 callersFunctionheader
Header component
A2A/demo/ui/components/header.py:7
↓ 6 callersFunctionpage_scaffold
Page scaffold component
A2A/demo/ui/components/page_scaffold.py:27
↓ 5 callersFunctionget_servers_dir
()
langchain-mcp-adapters/clients/util.py:3
↓ 5 callersFunctionpage_frame
Page Frame
A2A/demo/ui/components/page_scaffold.py:65
↓ 5 callersMethodsend_task_notification
(self, task: Task)
A2A/agents/llama_index_file_chat/task_manager.py:366
↓ 4 callersMethodcrew
Creates the Helloworld crew
crewai/helloworld/src/helloworld/crew.py:51
↓ 4 callersFunctionextract_content
( message_parts: list[Part], )
A2A/demo/ui/state/host_agent_service.py:228
↓ 4 callersFunctionform_state_to_string
(form: FormState)
A2A/demo/ui/components/form_render.py:357
↓ 4 callersMethodsend_task_notification
(self, task: Task)
A2A/agents/marvin/task_manager.py:282
↓ 3 callersFunctionSendMessage
(message: Message)
A2A/demo/ui/state/host_agent_service.py:46
↓ 3 callersMethod_initialize_host
(self)
A2A/demo/ui/service/server/adk_host_manager.py:100
↓ 3 callersFunction_to_text_part
(text: str)
A2A/agents/marvin/agent.py:20
↓ 3 callersMethod_update_store
( self, task_id: str, status: TaskStatus, artifacts: list[Artifact] )
A2A/agents/mindsdb/task_manager.py:131
↓ 3 callersMethod_validate_request
Validate task request parameters for compatibility with agent capabilities. Ensures that the client's requested output modalities are compati
A2A/agents/ag2/task_manager.py:243
↓ 3 callersMethodadd_event
(self, event: Event)
A2A/demo/ui/service/server/adk_host_manager.py:400
↓ 3 callersMethodattach_message_to_task
(self, message: Message | None, task_id: str)
A2A/demo/ui/service/server/adk_host_manager.py:317
↓ 3 callersFunctionconvert_message_to_state
(message: Message)
A2A/demo/ui/state/host_agent_service.py:176
↓ 3 callersFunctionget_agent_card
Get the agent card.
A2A/demo/ui/utils/agent_card.py:6
↓ 3 callersMethodget_conversation
( self, conversation_id: str | None )
A2A/demo/ui/service/server/adk_host_manager.py:403
↓ 3 callersMethodinsert_id_trace
(self, message: Message | None)
A2A/demo/ui/service/server/adk_host_manager.py:321
↓ 3 callersMethodinvoke
Process a user query with marvin Args: query: The user's input text. sessionId: The session identifier Retur
A2A/agents/marvin/agent.py:46
↓ 3 callersFunctionload_chat_model
Load a chat model from a fully specified name. Args: fully_specified_name (str): String in the format 'provider/model'.
langgraph-platform/agents/utils.py:20
↓ 3 callersFunctionmake_graph
(config: RunnableConfig)
langgraph-platform/agents/react_agent/graph.py:14
↓ 3 callersFunctionmake_nws_request
Make a request to the NWS API with proper error handling.
model_context_protocol/weather/weather.py:13
↓ 3 callersFunctionrun_assistant
(assistant)
langgraph-platform/client.py:36
↓ 3 callersMethodsend_task_notification
(self, task: Task)
A2A/agents/langgraph/task_manager.py:241
↓ 3 callersMethodsend_task_notification
Send a push notification for the task. Args: task: The task object containing the parameters.
A2A/agents/semantickernel/task_manager.py:235
↓ 3 callersMethodstream
Stream updates from the MCP agent.
A2A/agents/ag2/agent.py:108
↓ 3 callersMethodupdate_task
(self, task: Task)
A2A/demo/ui/service/server/adk_host_manager.py:238
↓ 2 callersFunctionListConversations
()
A2A/demo/ui/state/host_agent_service.py:37
↓ 2 callersFunctionUpdateApiKey
Update the API key
A2A/demo/ui/state/host_agent_service.py:156
↓ 2 callersFunctionUpdateAppState
Update the app state.
A2A/demo/ui/state/host_agent_service.py:123
↓ 2 callersMethod_ensure_thread_exists
Ensure the thread exists for the given session ID. Args: session_id (str): Unique identifier for the session.
A2A/agents/semantickernel/agent.py:273
↓ 2 callersMethod_extract_user_query
Extract the user's text query from the task parameters. Extracts and returns the text content from the first part of the user's message.
A2A/agents/ag2/task_manager.py:267
↓ 2 callersMethod_get_agent_response
Extracts the structured response from the agent's message content. Args: message (ChatMessageContent): The message content from t
A2A/agents/semantickernel/agent.py:230
↓ 2 callersMethod_get_input_event
Extract file attachment if present in the message parts.
A2A/agents/llama_index_file_chat/task_manager.py:344
↓ 2 callersMethod_get_user_query
(self, task_send_params: TaskSendParams)
A2A/agents/google_adk/task_manager.py:273
↓ 2 callersMethod_get_user_query
(self, task_send_params: TaskSendParams)
A2A/agents/langgraph/task_manager.py:235
↓ 2 callersMethod_get_user_query
(self, task_send_params: TaskSendParams)
A2A/agents/marvin/task_manager.py:276
↓ 2 callersMethod_get_user_query
(self, task_send_params: TaskSendParams)
A2A/agents/mindsdb/task_manager.py:172
↓ 2 callersMethod_parse_agent_outcome
Parses the dictionary output from agent.invoke() into A2A TaskStatus and Artifacts.
A2A/agents/marvin/task_manager.py:46
↓ 2 callersMethod_update_store
( self, task_id: str, status: TaskStatus, artifacts: list[Artifact] )
A2A/agents/google_adk/task_manager.py:232
↓ 2 callersMethod_validate_request
( self, request: SendTaskRequest | SendTaskStreamingRequest )
A2A/agents/llama_index_file_chat/task_manager.py:176
↓ 2 callersMethod_validate_request
( self, request: SendTaskRequest | SendTaskStreamingRequest )
A2A/agents/google_adk/task_manager.py:201
↓ 2 callersMethod_validate_request
( self, request: SendTaskRequest | SendTaskStreamingRequest )
A2A/agents/langgraph/task_manager.py:105
↓ 2 callersMethod_validate_request
Validate the request parameters. Args: request: The task request containing the parameters. Returns: JSONRPC
A2A/agents/semantickernel/task_manager.py:211
↓ 2 callersMethod_validate_request
( self, request: SendTaskRequest | SendTaskStreamingRequest )
A2A/agents/marvin/task_manager.py:164
↓ 2 callersMethod_validate_request
( self, request: SendTaskRequest | SendTaskStreamingRequest )
A2A/agents/mindsdb/task_manager.py:100
↓ 2 callersMethodadd_or_get_task
(self, task: TaskCallbackArg)
A2A/demo/ui/service/server/adk_host_manager.py:348
↓ 2 callersMethodadd_task
(self, task: Task)
A2A/demo/ui/service/server/adk_host_manager.py:235
↓ 2 callersFunctionchat_bubble
Chat bubble component
A2A/demo/ui/components/chat_bubble.py:7
↓ 2 callersFunctiondialog
(is_open: bool)
A2A/demo/ui/components/dialog.py:5
↓ 2 callersFunctiondialog_actions
()
A2A/demo/ui/components/dialog.py:42
↓ 2 callersFunctionextract_message_id
(message: Message)
A2A/demo/ui/state/host_agent_service.py:255
↓ 2 callersMethodformat
Format the response as a string.
A2A/agents/ag2/agent.py:27
↓ 2 callersMethodget_agent_response
(self, config)
A2A/agents/langgraph/agent.py:112
↓ 2 callersFunctionget_last_message_id
(m: Message | None)
A2A/demo/ui/service/server/adk_host_manager.py:600
↓ 2 callersFunctionmessage_string
(content: ContentPart)
A2A/demo/ui/components/task_card.py:9
↓ 2 callersFunctionsend_message
(message: str, message_id: str = '')
A2A/demo/ui/components/conversation.py:31
↓ 2 callersMethodset_push_notification_info
( self, task_id: str, push_notification_config: PushNotificationConfig )
A2A/agents/llama_index_file_chat/task_manager.py:397
↓ 2 callersMethodset_push_notification_info
( self, task_id: str, push_notification_config: PushNotificationConfig )
A2A/agents/langgraph/task_manager.py:272
↓ 2 callersMethodset_push_notification_info
( self, task_id: str, push_notification_config: PushNotificationConfig )
A2A/agents/marvin/task_manager.py:311
↓ 1 callersFunctionAddRemoteAgent
(path: str)
A2A/demo/ui/state/host_agent_service.py:73
↓ 1 callersFunctionCreateConversation
()
A2A/demo/ui/state/host_agent_service.py:55
↓ 1 callersFunctionGetEvents
()
A2A/demo/ui/state/host_agent_service.py:81
↓ 1 callersFunctionGetMessageAliases
()
A2A/demo/ui/state/host_agent_service.py:99
↓ 1 callersFunctionGetProcessingMessages
()
A2A/demo/ui/state/host_agent_service.py:90
↓ 1 callersFunctionGetTasks
()
A2A/demo/ui/state/host_agent_service.py:103
↓ 1 callersFunctionListMessages
(conversation_id: str)
A2A/demo/ui/state/host_agent_service.py:112
↓ 1 callersFunctionListRemoteAgents
()
A2A/demo/ui/state/host_agent_service.py:64
↓ 1 callersMethod__init__
(self, status_code: int, message: str)
A2A/demo/ui/service/types.py:124
↓ 1 callersMethod_build_agent
Builds the LLM agent for the reimbursement agent.
A2A/agents/google_adk/agent.py:131
↓ 1 callersMethod_get_user_query
(self, task_send_params: TaskSendParams)
A2A/agents/crewai/task_manager.py:124
↓ 1 callersMethod_handle_function_response
( self, part: types.Part, conversation_id: str )
A2A/demo/ui/service/server/adk_host_manager.py:550
↓ 1 callersMethod_handle_send_task
Handle the 'tasks/send' JSON-RPC method by processing agent response. This method processes the synchronous (one-time) response from the agen
A2A/agents/ag2/task_manager.py:116
↓ 1 callersMethod_handle_send_task_streaming
Handle the 'tasks/sendSubscribe' JSON-RPC method for streaming responses. This method processes streaming responses from the agent incrementa
A2A/agents/ag2/task_manager.py:148
↓ 1 callersMethod_invoke
(self, request: SendTaskRequest)
A2A/agents/google_adk/task_manager.py:250
↓ 1 callersMethod_invoke
(self, request: SendTaskRequest)
A2A/agents/mindsdb/task_manager.py:149
↓ 1 callersMethod_invoke
(self, request: SendTaskRequest)
A2A/agents/crewai/task_manager.py:93
↓ 1 callersMethod_process_agent_response
Processes the agent's response and updates the task store.
A2A/agents/langgraph/task_manager.py:209
↓ 1 callersMethod_process_agent_response
Process the agent's response and update the task status. Args: request: The task request containing the parameters. a
A2A/agents/semantickernel/task_manager.py:179
↓ 1 callersMethod_process_agent_response
Processes the agent's response and updates the task store.
A2A/agents/marvin/task_manager.py:261
↓ 1 callersMethod_run_streaming_agent
(self, request: SendTaskStreamingRequest)
A2A/agents/llama_index_file_chat/task_manager.py:67
↓ 1 callersMethod_run_streaming_agent
(self, request: SendTaskStreamingRequest)
A2A/agents/langgraph/task_manager.py:46
↓ 1 callersMethod_run_streaming_agent
A method to run the streaming agent. Args: request: The task streaming request containing the parameters. Yields:
A2A/agents/semantickernel/task_manager.py:97
↓ 1 callersMethod_run_streaming_agent
(self, request: SendTaskStreamingRequest)
A2A/agents/marvin/task_manager.py:83
↓ 1 callersMethod_stream_generator
( self, request: SendTaskStreamingRequest )
A2A/agents/google_adk/task_manager.py:126
↓ 1 callersMethod_stream_generator
( self, request: SendTaskStreamingRequest )
A2A/agents/mindsdb/task_manager.py:35
↓ 1 callersMethod_update_store
( self, task_id: str, status: TaskStatus, artifacts: list[Artifact] )
A2A/agents/crewai/task_manager.py:71
↓ 1 callersMethodadd_task
(self, task: Task)
A2A/demo/ui/service/server/in_memory_manager.py:120
↓ 1 callersMethodadk_content_from_message
(self, message: Message)
A2A/demo/ui/service/server/adk_host_manager.py:468
↓ 1 callersFunctionagent_list_page
Agents List Page
A2A/demo/ui/pages/agent_list.py:15
↓ 1 callersFunctionagents_list
Agents list component.
A2A/demo/ui/components/agent_list.py:9
↓ 1 callersFunctionasync_poller
Creates an invisible component that will delay state changes asynchronously. Right now this implementation is limited since we basically just pas
A2A/demo/ui/components/async_poller.py:17
↓ 1 callersFunctionbuild_graph
Build the workflow graph.
langgraph/helloworld.py:57
next →1–100 of 417, ranked by callers