Asserts that the workflow cancelled.

Asserts that the workflow completed successfully.

Asserts that the workflow continued as new and returns the command.

Asserts that the workflow failed.

Consumes and returns the next scheduled activity command.

Consumes and returns the next raw core command.

expected may be omitted, a command module, a full struct, or a one-argument predicate function.

Consumes and returns the next started timer command.

Asserts that the next command accepts the given update.

Asserts that the next command completes the given update.

Asserts that the next command rejects the given update.

Asserts that the current activation has no unconsumed commands.

Runs a query activation and asserts its successful result.

Replays the recorded activation transcript and asserts deterministic command emission.

Resolves a scheduled activity as cancelled.

Delivers workflow cancellation.

Resolves a scheduled activity handle with a workflow-visible result.

Resolves a scheduled activity as failed.

Fires a started timer handle.

Runs a query activation and returns the query result.

Asserts that the workflow has not completed successfully.

Runs an activity's real implementation directly — no Temporal anywhere.

This is the unit-test entry point for activity bodies (the workflow-side assert_next_activity/complete_activity kit is the complement: it tests the workflow by mocking the activity; this runs the activity itself).

assert {:ok, receipt} = Temporalex.Testing.run_activity(Activities, :charge, [100])

For activities that declare a ctx argument, a Temporalex.Activity.Context is fabricated with honest defaults (attempt: 1, the real wire type, no worker — so heartbeat/2 is a no-op) and context: merges overrides:

Temporalex.Testing.run_activity(Activities, :poll, [job],
  context: [attempt: 3, cancelled: true]
)

cancelled: true seeds the cancellation flag so Activity.cancelled?/1 and heartbeats report cancellation. Passing context: to an activity that never declares ctx raises — that test would be asserting fiction.

Returns whatever the implementation returns, untouched.

Like run_activity/4 but unwraps success and raises failures.

Activities must return {:ok, value} or {:error, reason} (the server enforces the same contract); anything else raises here too, so a test fails the same way production would.

Payments |> Temporalex.Testing.run_activity!(:charge, [100])

Delivers a signal to the workflow run.

Returns a debugging snapshot of the testing runner.

Starts a workflow run in the testing runner.

The workflow is initialized immediately. Any commands emitted by the first activation are available through assert_next_activity/2, assert_next_timer/2, or assert_next_command/2.

Delivers an update to the workflow run and returns an update handle.