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
2 changes: 1 addition & 1 deletion .github/workflows/stale.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ name: Mark stale issues and pull requests

on:
schedule:
# Scheduled to run at 10.30PM UTC everyday (1530PDT/1430PST)
# Scheduled to run at 10.30PM UTC every day (1530PDT/1430PST)
- cron: "30 22 * * *"
workflow_dispatch:

Expand Down
2 changes: 1 addition & 1 deletion src/a2a/client/client_factory.py
Original file line number Diff line number Diff line change
Expand Up @@ -256,7 +256,7 @@ def minimal_agent_card(
"""Generates a minimal card to simplify bootstrapping client creation.

This minimal card is not viable itself to interact with the remote agent.
Instead this is a short hand way to take a known url and transport option
Instead this is a shorthand way to take a known url and transport option
and interact with the get card endpoint of the agent server to get the
correct agent card. This pattern is necessary for gRPC based card access
as typically these servers won't expose a well known path card.
Expand Down
2 changes: 1 addition & 1 deletion src/a2a/server/events/event_queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ async def dequeue_event(self, no_wait: bool = False) -> Event:
closed but when there are no events on the queue. Two ways to avoid this
are to call this with no_wait = True which won't block, but is the
callers responsibility to retry as appropriate. Alternatively, one can
use a async Task management solution to cancel the get task if the queue
use an async Task management solution to cancel the get task if the queue
has closed or some other condition is met. The implementation of the
EventConsumer uses an async.wait with a timeout to abort the
dequeue_event call and retry, when it will return with a closed error.
Expand Down
4 changes: 2 additions & 2 deletions tests/e2e/push_notifications/notifications_app.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ def create_notifications_app() -> FastAPI:

@app.post('/notifications')
async def add_notification(request: Request):
"""Endpoint for injesting notifications from agents. It receives a JSON
"""Endpoint for ingesting notifications from agents. It receives a JSON
payload and stores it in-memory.
"""
token = request.headers.get('x-a2a-notification-token')
Expand Down Expand Up @@ -56,7 +56,7 @@ async def list_notifications_by_task(
str, Path(title='The ID of the task to list the notifications for.')
],
):
"""Helper endpoint for retrieving injested notifications for a given task."""
"""Helper endpoint for retrieving ingested notifications for a given task."""
async with store_lock:
notifications = store.get(task_id, [])
return {'notifications': notifications}
Expand Down
2 changes: 1 addition & 1 deletion tests/server/events/test_event_queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -305,7 +305,7 @@ async def test_close_sets_flag_and_handles_internal_queue_new_python(
async def test_close_graceful_py313_waits_for_join_and_children(
event_queue: EventQueue,
) -> None:
"""For Python >=3.13 and immediate=False, close should shutdown(False), then wait for join and children."""
"""For Python >=3.13 and immediate=False, close should shut down(False), then wait for join and children."""
with patch('sys.version_info', (3, 13, 0)):
# Arrange
from typing import cast
Expand Down
Loading