Runs

wf = client.workflows.get(workflow_id)
run = wf.run({"Input 1": "hello"})               # -> Run (queued)
result = run.wait(output_only=True)              # blocks (polls every 5s), returns output
# or step through progress events:
for event in wf.run_and_stream({"Input 1": "hello"}):
    print(event)

out = client.runs.run_sync(workflow_id, {"Input 1": "hello"}, output_only=True)

client.runs.list(workflow_id, page=1, page_size=10)      # -> list[Run]
client.runs.get(workflow_id, run_id)                     # -> Run
client.runs.run_sync(workflow_id, input, output_only=False)
client.runs.stop(run_id)                                 # -> Run (cancel)
client.runs.get_data(run_id, fetch_structured_data=True) # full run payload
client.runs.get_node_io(run_id, node_id, it=0)           # a node's inputs/outputs
client.runs.search("invoice", limit=10, exact=True, search_in=None)  # search across runs

run.wait(interval=5, output_only=False)   # poll until terminal; returns Run or output dict
run.get_status()                          # -> str
run.refresh()                             # re-fetch
run.stop()                                # cancel
run.data(fetch_structured_data=True)      # full payload
for event in run.stream(etag=None):       # live RunEvents
    print(event)

from datetime import datetime, timedelta, timezone

# One run
client.runs.delete(run_id)                       # -> RunDeletion
run.delete()                                     # same, from a Run object

# Everything older than 90 days, optionally scoped to one workflow
cutoff = datetime.now(timezone.utc) - timedelta(days=90)
preview = client.runs.bulk_delete(older_than=cutoff, workflow_id=wf.id, dry_run=True)
print(preview.matched)                           # finished runs that would go

result = client.runs.bulk_delete(
    older_than=cutoff,
    workflow_id=wf.id,
    expected_count=preview.matched,              # HTTP 409 if the count changed
)
print(result.succeeded, result.errors)

# Specific runs
client.runs.bulk_delete(run_ids=[run_a.id, run_b.id])