Python

from threadify import Threadify, WaitOptions

connection = await Threadify.connect(
    api_key,
    engine_url="https://threadify.example.com",
    service_name="payments",
)
threads = await connection.get_threads_by_ref({"order_id": "ORD-1001"})
thread = await connection.join(thread_id, "processor")
grant = await thread.wait_for("charge", WaitOptions(timeout=15))
# Perform the permitted operation before reporting it.
result = await thread.step("charge").add_context({"amount": 42}).success(
    "charged", wait_for=True, timeout=15,
)
await thread.wait_for_validation("charge", result.step_id)