Long running Tools

region = "REGION CODE AS INSTRUCTED in the API keys page"
authorization_token = "AUTHORIZATION TOKEN AS INSTRUCTED in the API keys page"

studio_id = "STUDIO ID AS INSTRUCTED ABOVE"

https://api-<Region>.stack.tryrelevance.com/latest/studios/list_public?filters=${JSON.stringify([{ filter_type: 'exact_match', field: 'title', condition_value: <ToolTitle>}])}

import requests
import json

tool_title = "xxxxxxxxxx"
headers = {"Authorization": authorization_token}

filters = json.dumps([{ "filter_type": 'exact_match', "field": 'title', "condition_value": tool_title}])
url = f"https://api-{region}.stack.tryrelevance.com/latest/studios/list_public?filters={filters}"

tool_info = requests.get(url, headers=headers).json()["results"][0]
tool_inputs = tool_info["params_schema"]["properties"]

# Start long running tool
url = f"https://api-{region}.stack.tryrelevance.com/latest/studios/{studio_id}/trigger_async"
headers = {
    "Authorization": authorization_token,
    "Content-Type": "application/json"
}
payload = {"params":tool_inputs}
response = requests.post(url, headers=headers, json=payload)

# Extract the tools job id, so we can check its progress
job_id = response.json()['job_id']

# Every 5 seconds, check if the tool had finished by calling the poll endpoint
poll_url = f"https://api-{region}.stack.tryrelevance.com/latest/studios/{studio_id}/async_poll/{job_id}?ending_update_only=true"
tool_output = {}
for _ in range(100):
  poll_response = requests.get(poll_url,headers=headers).json()
  print(poll_response)
  if poll_response['type'] == "complete" or poll_response['type'] == 'failed':
    print(poll_response)
    tool_output = poll_response["updates"][0]["output"]["output"]
    break
  time.sleep(5)

# This is the tools output
print('Tool-output',tool_output)