Function pollForJobCompletion

sdk-node/src/polling.ts:272–307

(
  client: ReturnType<typeof createApiClient>,
  clusterId: string,
  jobId: string,
  initialStatus?: string | null,
  initialResult: string = "",
  initialResultType: string = "rejection",
)

};

export const pollForJobCompletion = async (
  client: ReturnType<typeof createApiClient>,
  clusterId: string,
  jobId: string,
  initialStatus?: string | null,
  initialResult: string = "",
  initialResultType: string = "rejection",
): Promise<{
  status: string;
  result: string;
  resultType: string;
}> => {
  let status: string | null = initialStatus ?? null;
  let result: string = initialResult;
  let resultType: string = initialResultType;

  while (!status || !["failure", "done"].includes(status)) {
    const details = await client.getJob({
      params: { clusterId, jobId },
      query: { waitTime: 20 },
    });

    if (details.status !== 200) {
      throw new AgentRPCError(`Failed to fetch job details: ${details.status}`);
    }

    const body = details.body;
    status = body.status;
    result = body.result || "";
    resultType = body.resultType || "rejection";

    await new Promise((resolve) => setTimeout(resolve, 1000));
  }

  return { status: status as string, result, resultType };
};

export const createAndPollJob = async (
  client: ReturnType<typeof createApiClient>,