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)