Function createAndPollJob

sdk-node/src/polling.ts:309–343

(
  client: ReturnType<typeof createApiClient>,
  clusterId: string,
  toolName: string,
  // eslint-disable-next-line @typescript-eslint/no-explicit-any
  input: any,
)

};

export const createAndPollJob = async (
  client: ReturnType<typeof createApiClient>,
  clusterId: string,
  toolName: string,
  // eslint-disable-next-line @typescript-eslint/no-explicit-any
  input: any,
): Promise<{
  status: string;
  result: string;
  resultType: string;
}> => {
  const createResult = await client.createJob({
    body: {
      tool: toolName,
      input,
    },
    params: { clusterId },
    query: {
      waitTime: 20,
    },
  });

  if (createResult.status !== 200) {
    throw new AgentRPCError(`Failed to run tool: ${createResult.status}`);
  }

  return pollForJobCompletion(
    client,
    clusterId,
    createResult.body.id,
    createResult.body.status,
    createResult.body.result || "",
    createResult.body.resultType || "rejection",
  );
};