harnest.testing

All Python modules · Import and compatibility guidance

Smoke client operations

Method	Returns
`smoke.respond(...)`	One neutral JSON response
`smoke.stream(...)`	Ordered SSE event objects

Exports

Name	Kind
`AgentTestError`	Class
`ChannelStoreConformanceMixin`	Class
`MemoryStoreConformanceMixin`	Class
`SmokeClient`	Class
`TaskStoreConformanceMixin`	Class
`run_agent_tests`	Function

AgentTestError

An authored test suite does not follow the Harnest convention.

Example

from harnest.testing import AgentTestError

try:
    ...
except AgentTestError as error:
    ...

ChannelStoreConformanceMixin

Subclass with IsolatedAsyncioTestCase and an async make_store factory.

ChannelStoreConformanceMixin()

Example

from harnest.testing import ChannelStoreConformanceMixin

mixin = ChannelStoreConformanceMixin()

ChannelStoreConformanceMixin.make_store

async ChannelStoreConformanceMixin.make_store() -> Any

Override to return an unstarted provider implementing ChannelStore. Tests use a unique installation scope per case. Register backend cleanup with addAsyncCleanup; the mixin owns starting and closing it.

Example

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
result = await mixin.make_store()

ChannelStoreConformanceMixin.asyncSetUp

async ChannelStoreConformanceMixin.asyncSetUp() -> None

Give every check its own installation scope and provider lifecycle.

Example

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
await mixin.asyncSetUp()

ChannelStoreConformanceMixin.channel_event

ChannelStoreConformanceMixin.channel_event(provider_event_id: str = 'evt', **changes: Any) -> ChannelEvent

Build deterministic safe event input independently of provider details.

Parameters and example

Parameter	Type	Default
`provider_event_id`	`str`	`'evt'`
`**changes`	`Any`	Optional

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
event = mixin.channel_event()

ChannelStoreConformanceMixin.channel_reply

ChannelStoreConformanceMixin.channel_reply(reply_id: str = 'reply', **changes: Any) -> ChannelReply

Build one queued reply targeting this scope’s default conversation.

Parameters and example

Parameter	Type	Default
`reply_id`	`str`	`'reply'`
`**changes`	`Any`	Optional

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
reply = mixin.channel_reply()

ChannelStoreConformanceMixin.test_admit_is_idempotent_conflict_checked_and_scope_isolated

async ChannelStoreConformanceMixin.test_admit_is_idempotent_conflict_checked_and_scope_isolated() -> None

Concurrent retries admit once and reject a changed redefinition.

Example

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
await mixin.test_admit_is_idempotent_conflict_checked_and_scope_isolated()

ChannelStoreConformanceMixin.test_get_event_reads_only_the_admitted_identity

async ChannelStoreConformanceMixin.test_get_event_reads_only_the_admitted_identity() -> None

Reads are scoped to platform, installation, and provider event ID.

Example

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
await mixin.test_get_event_reads_only_the_admitted_identity()

ChannelStoreConformanceMixin.test_session_binding_is_first_write_wins

async ChannelStoreConformanceMixin.test_session_binding_is_first_write_wins() -> None

A conversation scope keeps its first bound session across retries.

Example

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
await mixin.test_session_binding_is_first_write_wins()

ChannelStoreConformanceMixin.test_reply_lifecycle_claims_pending_and_finishes_once

async ChannelStoreConformanceMixin.test_reply_lifecycle_claims_pending_and_finishes_once() -> None

Replies are claimable while pending and terminal exactly once.

Example

from harnest.testing import ChannelStoreConformanceMixin

mixin: ChannelStoreConformanceMixin
await mixin.test_reply_lifecycle_claims_pending_and_finishes_once()

MemoryStoreConformanceMixin

Combine with IsolatedAsyncioTestCase and implement async make_store().

MemoryStoreConformanceMixin()

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin = MemoryStoreConformanceMixin()

MemoryStoreConformanceMixin.make_store

async MemoryStoreConformanceMixin.make_store() -> harnest.memory.MemoryStore

Return an unstarted provider; register any test-data cleanup yourself.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
store = await mixin.make_store()

MemoryStoreConformanceMixin.asyncSetUp

async MemoryStoreConformanceMixin.asyncSetUp() -> None

Own a fresh provider and unique application scope for each check.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.asyncSetUp()

MemoryStoreConformanceMixin.record

MemoryStoreConformanceMixin.record(key: str = 'preference', **changes: Any) -> harnest.memory.MemoryRecord

Build a valid explicit write without coupling tests to a datastore.

Parameters and example

Parameter	Type	Default
`key`	`str`	`'preference'`
`**changes`	`Any`	Optional

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
record = mixin.record()

MemoryStoreConformanceMixin.test_memory_is_scoped_and_explicit

async MemoryStoreConformanceMixin.test_memory_is_scoped_and_explicit() -> None

Identical keys never cross application, user or namespace boundaries.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_is_scoped_and_explicit()

MemoryStoreConformanceMixin.test_memory_results_are_detached

async MemoryStoreConformanceMixin.test_memory_results_are_detached() -> None

Callers cannot silently mutate persisted metadata through returned objects.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_results_are_detached()

MemoryStoreConformanceMixin.test_memory_json_roundtrip_is_lossless

async MemoryStoreConformanceMixin.test_memory_json_roundtrip_is_lossless() -> None

Provider scripting must preserve arrays, exact integers and floats.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_json_roundtrip_is_lossless()

MemoryStoreConformanceMixin.test_memory_maintenance_preserves_other_owners

async MemoryStoreConformanceMixin.test_memory_maintenance_preserves_other_owners() -> None

Bulk erasure includes expired records but never another application/user.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_maintenance_preserves_other_owners()

MemoryStoreConformanceMixin.test_memory_purge_physically_removes_expired_pages

async MemoryStoreConformanceMixin.test_memory_purge_physically_removes_expired_pages() -> None

Zero-deletion pages continue and live data survives a bounded sweep.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_purge_physically_removes_expired_pages()

MemoryStoreConformanceMixin.test_memory_revision_fences_concurrent_writers

async MemoryStoreConformanceMixin.test_memory_revision_fences_concurrent_writers() -> None

Exactly one writer can replace the same revision across concurrent calls.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_revision_fences_concurrent_writers()

MemoryStoreConformanceMixin.test_memory_delete_does_not_allow_stale_resurrection

async MemoryStoreConformanceMixin.test_memory_delete_does_not_allow_stale_resurrection() -> None

Deletion removes search membership and invalidates earlier revisions.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_delete_does_not_allow_stale_resurrection()

MemoryStoreConformanceMixin.test_memory_pages_and_literal_search

async MemoryStoreConformanceMixin.test_memory_pages_and_literal_search() -> None

Paginate datastore-filtered results without interpreting wildcard syntax.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_pages_and_literal_search()

MemoryStoreConformanceMixin.test_memory_expiry_hides_records_and_fences_updates

async MemoryStoreConformanceMixin.test_memory_expiry_hides_records_and_fences_updates() -> None

Expiry applies to get, list, search and conditional mutation alike.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_expiry_hides_records_and_fences_updates()

MemoryStoreConformanceMixin.test_memory_rejects_invalid_payloads_and_limits

async MemoryStoreConformanceMixin.test_memory_rejects_invalid_payloads_and_limits() -> None

Validation never silently truncates private data or unbounded queries.

Example

from harnest.testing import MemoryStoreConformanceMixin

mixin: MemoryStoreConformanceMixin
await mixin.test_memory_rejects_invalid_payloads_and_limits()

SmokeClient

Small neutral-API helper injected into opted-in smoke tests.

SmokeClient(client: Any) -> None

Parameters and example

Parameter	Type	Default
`client`	`Any`	Required

from harnest.testing import SmokeClient

client = SmokeClient(client=...)

SmokeClient.respond

SmokeClient.respond(
    input: str,
    *,
    session_id: str | None = None,
    metadata: Mapping[str, Any] | None = None,
) -> dict[str, Any]

Invoke the neutral response endpoint and return its JSON object.

Parameters and example

Parameter	Type	Default
`input`	`str`	Required
`session_id`	`str \| None`	`None`
`metadata`	`Mapping[str, Any] \| None`	`None`

from harnest.testing import SmokeClient

client: SmokeClient
result = client.respond(input=...)

SmokeClient.stream

SmokeClient.stream(
    input: str,
    *,
    session_id: str | None = None,
    metadata: Mapping[str, Any] | None = None,
) -> list[dict[str, Any]]

Invoke the streaming endpoint and return parsed server-sent events.

Parameters and example

Parameter	Type	Default
`input`	`str`	Required
`session_id`	`str \| None`	`None`
`metadata`	`Mapping[str, Any] \| None`	`None`

from harnest.testing import SmokeClient

client: SmokeClient
result = client.stream(input=...)

TaskStoreConformanceMixin

Subclass with IsolatedAsyncioTestCase and an async make_store factory.

TaskStoreConformanceMixin()

Example

from harnest.testing import TaskStoreConformanceMixin

mixin = TaskStoreConformanceMixin()

TaskStoreConformanceMixin.make_store

async TaskStoreConformanceMixin.make_store() -> Any

Override to return an unstarted provider implementing both contracts. Tests use a unique application scope per case. Register backend cleanup with addAsyncCleanup; the mixin owns starting and closing the provider.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
result = await mixin.make_store()

TaskStoreConformanceMixin.asyncSetUp

async TaskStoreConformanceMixin.asyncSetUp() -> None

Give every check its own application scope and provider lifecycle.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.asyncSetUp()

TaskStoreConformanceMixin.task_record

TaskStoreConformanceMixin.task_record(job_id: str = 'job', **changes: Any) -> TaskRecord

Build deterministic safe job input independently of provider details.

Parameters and example

Parameter	Type	Default
`job_id`	`str`	`'job'`
`**changes`	`Any`	Optional

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
record = mixin.task_record()

TaskStoreConformanceMixin.cron_record

TaskStoreConformanceMixin.cron_record(schedule_id: str = 'cron', **changes: Any) -> CronRecord

Build one due user schedule with stable ownership and definition.

Parameters and example

Parameter	Type	Default
`schedule_id`	`str`	`'cron'`
`**changes`	`Any`	Optional

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
record = mixin.cron_record()

TaskStoreConformanceMixin.claim

async TaskStoreConformanceMixin.claim(**changes: Any) -> tuple[TaskRecord, ...]

Claim one bounded batch through the shared worker contract.

Parameters and example

Parameter	Type	Default
`**changes`	`Any`	Optional

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
result = await mixin.claim()

TaskStoreConformanceMixin.read_task

async TaskStoreConformanceMixin.read_task(job_id: str = 'job', user_id: str = 'alice') -> TaskRecord | None

Read a task as the selected owner.

Parameters and example

Parameter	Type	Default
`job_id`	`str`	`'job'`
`user_id`	`str`	`'alice'`

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
record = await mixin.read_task()

TaskStoreConformanceMixin.finish

async TaskStoreConformanceMixin.finish(record: TaskRecord, **changes: Any) -> bool

Finish the exact lease with deterministic test timestamps.

Parameters and example

Parameter	Type	Default
`record`	`TaskRecord`	Required
`**changes`	`Any`	Optional

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
result = await mixin.finish(record=...)

TaskStoreConformanceMixin.test_enqueue_is_atomic_idempotent_and_owner_scoped

async TaskStoreConformanceMixin.test_enqueue_is_atomic_idempotent_and_owner_scoped() -> None

Concurrent retries produce one job without crossing task/user scope.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_enqueue_is_atomic_idempotent_and_owner_scoped()

TaskStoreConformanceMixin.test_completed_task_retains_idempotency_but_scrubs_payload

async TaskStoreConformanceMixin.test_completed_task_retains_idempotency_but_scrubs_payload() -> None

Private inputs disappear while retained fingerprints deduplicate retries.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_completed_task_retains_idempotency_but_scrubs_payload()

TaskStoreConformanceMixin.test_claim_filters_due_queue_and_application_and_never_duplicates

async TaskStoreConformanceMixin.test_claim_filters_due_queue_and_application_and_never_duplicates() -> None

Replicas atomically claim distinct jobs using datastore scope predicates.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_claim_filters_due_queue_and_application_and_never_duplicates()

TaskStoreConformanceMixin.test_expired_lease_cannot_finish_and_reclaim_uses_new_token

async TaskStoreConformanceMixin.test_expired_lease_cannot_finish_and_reclaim_uses_new_token() -> None

Fencing rejects old workers before and after a replacement claim.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_expired_lease_cannot_finish_and_reclaim_uses_new_token()

TaskStoreConformanceMixin.test_renewal_prevents_early_reclaim

async TaskStoreConformanceMixin.test_renewal_prevents_early_reclaim() -> None

A valid heartbeat extends exclusive attempt ownership.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_renewal_prevents_early_reclaim()

TaskStoreConformanceMixin.test_retry_delay_and_exhausted_crash_recovery

async TaskStoreConformanceMixin.test_retry_delay_and_exhausted_crash_recovery() -> None

Retries retain inputs and crashed final attempts reach a terminal state.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_retry_delay_and_exhausted_crash_recovery()

TaskStoreConformanceMixin.test_cancellation_is_scoped_terminal_and_fences_running_attempt

async TaskStoreConformanceMixin.test_cancellation_is_scoped_terminal_and_fences_running_attempt() -> None

Cancellation cannot reveal another owner’s work or accept late results.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_cancellation_is_scoped_terminal_and_fences_running_attempt()

TaskStoreConformanceMixin.test_snapshots_do_not_share_mutable_payload

async TaskStoreConformanceMixin.test_snapshots_do_not_share_mutable_payload() -> None

Mutating submitted or returned objects cannot rewrite durable records.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_snapshots_do_not_share_mutable_payload()

TaskStoreConformanceMixin.test_cron_idempotency_revision_and_terminal_cancellation

async TaskStoreConformanceMixin.test_cron_idempotency_revision_and_terminal_cancellation() -> None

Definition retry preserves inactive state and stale edits cannot win.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_cron_idempotency_revision_and_terminal_cancellation()

TaskStoreConformanceMixin.test_cron_lists_enforce_owner_due_state_and_keyset_pagination

async TaskStoreConformanceMixin.test_cron_lists_enforce_owner_due_state_and_keyset_pagination() -> None

Due pagination includes equal timestamps without leaking foreign scopes.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_cron_lists_enforce_owner_due_state_and_keyset_pagination()

TaskStoreConformanceMixin.test_cron_occurrence_commit_is_atomic_and_exactly_deduplicated

async TaskStoreConformanceMixin.test_cron_occurrence_commit_is_atomic_and_exactly_deduplicated() -> None

Concurrent dispatchers advance once and commit exactly one runnable job.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_cron_occurrence_commit_is_atomic_and_exactly_deduplicated()

TaskStoreConformanceMixin.test_cron_max_runs_caps_atomic_handoffs

async TaskStoreConformanceMixin.test_cron_max_runs_caps_atomic_handoffs() -> None

A schedule cannot enqueue more occurrences than its run cap.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_cron_max_runs_caps_atomic_handoffs()

TaskStoreConformanceMixin.test_cron_failure_streak_resets_after_success

async TaskStoreConformanceMixin.test_cron_failure_streak_resets_after_success() -> None

Only consecutive terminal failures stop later occurrences.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_cron_failure_streak_resets_after_success()

TaskStoreConformanceMixin.test_cancelled_cron_cannot_commit_and_conflict_rolls_back_cursor

async TaskStoreConformanceMixin.test_cancelled_cron_cannot_commit_and_conflict_rolls_back_cursor() -> None

A cancelled/stale schedule or failed enqueue leaves no partial handoff.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_cancelled_cron_cannot_commit_and_conflict_rolls_back_cursor()

TaskStoreConformanceMixin.test_occurrence_cannot_substitute_schedule_arguments

async TaskStoreConformanceMixin.test_occurrence_cannot_substitute_schedule_arguments() -> None

Atomic handoff must preserve the validated schedule’s authored input.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_occurrence_cannot_substitute_schedule_arguments()

TaskStoreConformanceMixin.test_limits_reject_unbounded_or_ambiguous_requests

async TaskStoreConformanceMixin.test_limits_reject_unbounded_or_ambiguous_requests() -> None

Providers share the public bounded-page contract before datastore I/O.

Example

from harnest.testing import TaskStoreConformanceMixin

mixin: TaskStoreConformanceMixin
await mixin.test_limits_reject_unbounded_or_ambiguous_requests()

run_agent_tests

Test authored source with eval preparation progress and optional quiet output.

run_agent_tests(
    source: str | Path,
    *,
    include_smoke: bool = False,
    include_evals: bool = False,
    eval_trajectory: str = 'business',
    no_output: bool = False,
    eval_output: Path | None = None,
    framework: str = 'adk',
    mode: str = 'managed',
    cli_enabled: bool = False,
) -> int

Parameters and example

Parameter	Type	Default
`source`	`str \| Path`	Required
`include_smoke`	`bool`	`False`
`include_evals`	`bool`	`False`
`eval_trajectory`	`str`	`'business'`
`no_output`	`bool`	`False`
`eval_output`	`Path \| None`	`None`
`framework`	`str`	`'adk'`
`mode`	`str`	`'managed'`
`cli_enabled`	`bool`	`False`

from harnest.testing import run_agent_tests

result = run_agent_tests(source=...)

​Smoke client operations

​Exports

​AgentTestError

​ChannelStoreConformanceMixin

​ChannelStoreConformanceMixin.make_store

​ChannelStoreConformanceMixin.asyncSetUp

​ChannelStoreConformanceMixin.channel_event

​ChannelStoreConformanceMixin.channel_reply

​ChannelStoreConformanceMixin.test_admit_is_idempotent_conflict_checked_and_scope_isolated

​ChannelStoreConformanceMixin.test_get_event_reads_only_the_admitted_identity

​ChannelStoreConformanceMixin.test_session_binding_is_first_write_wins

​ChannelStoreConformanceMixin.test_reply_lifecycle_claims_pending_and_finishes_once

​MemoryStoreConformanceMixin

​MemoryStoreConformanceMixin.make_store

​MemoryStoreConformanceMixin.asyncSetUp

​MemoryStoreConformanceMixin.record

​MemoryStoreConformanceMixin.test_memory_is_scoped_and_explicit

​MemoryStoreConformanceMixin.test_memory_results_are_detached

​MemoryStoreConformanceMixin.test_memory_json_roundtrip_is_lossless

​MemoryStoreConformanceMixin.test_memory_maintenance_preserves_other_owners

​MemoryStoreConformanceMixin.test_memory_purge_physically_removes_expired_pages

​MemoryStoreConformanceMixin.test_memory_revision_fences_concurrent_writers

​MemoryStoreConformanceMixin.test_memory_delete_does_not_allow_stale_resurrection

​MemoryStoreConformanceMixin.test_memory_pages_and_literal_search

​MemoryStoreConformanceMixin.test_memory_expiry_hides_records_and_fences_updates

​MemoryStoreConformanceMixin.test_memory_rejects_invalid_payloads_and_limits

​SmokeClient

​SmokeClient.respond

​SmokeClient.stream

​TaskStoreConformanceMixin

​TaskStoreConformanceMixin.make_store

​TaskStoreConformanceMixin.asyncSetUp

​TaskStoreConformanceMixin.task_record

​TaskStoreConformanceMixin.cron_record

​TaskStoreConformanceMixin.claim

​TaskStoreConformanceMixin.read_task

​TaskStoreConformanceMixin.finish

​TaskStoreConformanceMixin.test_enqueue_is_atomic_idempotent_and_owner_scoped

​TaskStoreConformanceMixin.test_completed_task_retains_idempotency_but_scrubs_payload

​TaskStoreConformanceMixin.test_claim_filters_due_queue_and_application_and_never_duplicates

​TaskStoreConformanceMixin.test_expired_lease_cannot_finish_and_reclaim_uses_new_token

​TaskStoreConformanceMixin.test_renewal_prevents_early_reclaim

​TaskStoreConformanceMixin.test_retry_delay_and_exhausted_crash_recovery

​TaskStoreConformanceMixin.test_cancellation_is_scoped_terminal_and_fences_running_attempt

​TaskStoreConformanceMixin.test_snapshots_do_not_share_mutable_payload

​TaskStoreConformanceMixin.test_cron_idempotency_revision_and_terminal_cancellation

​TaskStoreConformanceMixin.test_cron_lists_enforce_owner_due_state_and_keyset_pagination

​TaskStoreConformanceMixin.test_cron_occurrence_commit_is_atomic_and_exactly_deduplicated

​TaskStoreConformanceMixin.test_cron_max_runs_caps_atomic_handoffs

​TaskStoreConformanceMixin.test_cron_failure_streak_resets_after_success

​TaskStoreConformanceMixin.test_cancelled_cron_cannot_commit_and_conflict_rolls_back_cursor

​TaskStoreConformanceMixin.test_occurrence_cannot_substitute_schedule_arguments

​TaskStoreConformanceMixin.test_limits_reject_unbounded_or_ambiguous_requests

​run_agent_tests

Smoke client operations

Exports

AgentTestError

ChannelStoreConformanceMixin

ChannelStoreConformanceMixin.make_store

ChannelStoreConformanceMixin.asyncSetUp

ChannelStoreConformanceMixin.channel_event

ChannelStoreConformanceMixin.channel_reply

ChannelStoreConformanceMixin.test_admit_is_idempotent_conflict_checked_and_scope_isolated

ChannelStoreConformanceMixin.test_get_event_reads_only_the_admitted_identity

ChannelStoreConformanceMixin.test_session_binding_is_first_write_wins

ChannelStoreConformanceMixin.test_reply_lifecycle_claims_pending_and_finishes_once

MemoryStoreConformanceMixin

MemoryStoreConformanceMixin.make_store

MemoryStoreConformanceMixin.asyncSetUp

MemoryStoreConformanceMixin.record

MemoryStoreConformanceMixin.test_memory_is_scoped_and_explicit

MemoryStoreConformanceMixin.test_memory_results_are_detached

MemoryStoreConformanceMixin.test_memory_json_roundtrip_is_lossless

MemoryStoreConformanceMixin.test_memory_maintenance_preserves_other_owners

MemoryStoreConformanceMixin.test_memory_purge_physically_removes_expired_pages

MemoryStoreConformanceMixin.test_memory_revision_fences_concurrent_writers

MemoryStoreConformanceMixin.test_memory_delete_does_not_allow_stale_resurrection

MemoryStoreConformanceMixin.test_memory_pages_and_literal_search

MemoryStoreConformanceMixin.test_memory_expiry_hides_records_and_fences_updates

MemoryStoreConformanceMixin.test_memory_rejects_invalid_payloads_and_limits

SmokeClient

SmokeClient.respond

SmokeClient.stream

TaskStoreConformanceMixin

TaskStoreConformanceMixin.make_store

TaskStoreConformanceMixin.asyncSetUp

TaskStoreConformanceMixin.task_record

TaskStoreConformanceMixin.cron_record

TaskStoreConformanceMixin.claim

TaskStoreConformanceMixin.read_task

TaskStoreConformanceMixin.finish

TaskStoreConformanceMixin.test_enqueue_is_atomic_idempotent_and_owner_scoped

TaskStoreConformanceMixin.test_completed_task_retains_idempotency_but_scrubs_payload

TaskStoreConformanceMixin.test_claim_filters_due_queue_and_application_and_never_duplicates

TaskStoreConformanceMixin.test_expired_lease_cannot_finish_and_reclaim_uses_new_token

TaskStoreConformanceMixin.test_renewal_prevents_early_reclaim

TaskStoreConformanceMixin.test_retry_delay_and_exhausted_crash_recovery

TaskStoreConformanceMixin.test_cancellation_is_scoped_terminal_and_fences_running_attempt

TaskStoreConformanceMixin.test_snapshots_do_not_share_mutable_payload

TaskStoreConformanceMixin.test_cron_idempotency_revision_and_terminal_cancellation

TaskStoreConformanceMixin.test_cron_lists_enforce_owner_due_state_and_keyset_pagination

TaskStoreConformanceMixin.test_cron_occurrence_commit_is_atomic_and_exactly_deduplicated

TaskStoreConformanceMixin.test_cron_max_runs_caps_atomic_handoffs

TaskStoreConformanceMixin.test_cron_failure_streak_resets_after_success

TaskStoreConformanceMixin.test_cancelled_cron_cannot_commit_and_conflict_rolls_back_cursor

TaskStoreConformanceMixin.test_occurrence_cannot_substitute_schedule_arguments

TaskStoreConformanceMixin.test_limits_reject_unbounded_or_ambiguous_requests

run_agent_tests