Polling

1
import { VideoGenClient, pollWorkflowRun } from "@videogen/sdk";
2
3
const client = new VideoGenClient({ token: process.env.VIDEOGEN_API_KEY });
4
5
const { workflowRunId } = await client.workflows.scriptToVideo({
6
  script:
7
    "Staying hydrated keeps your body and mind running at their best. Drinking enough water boosts your energy, focus, and mood. Keep a water bottle nearby and sip throughout the day.",
8
  visualStyle: {
9
    type: "AI_IMAGE",
10
    aiStyle: "loose watercolor illustration with visible brushstrokes and soft color bleeds",
11
  },
12
  quality: "HIGH",
13
  remixActions: [
14
    { type: "ENABLE_CAPTIONS" },
15
    { type: "SET_BACKGROUND_MUSIC", fileId: "vg_file_...", volume: 0.25 },
16
  ],
17
});
18
19
const run = await pollWorkflowRun(client, workflowRunId);
20
console.log(run.status, run.projectUrl);

1
import { pollExecutedTool } from "@videogen/sdk";
2
3
const { toolExecutionId } = await client.tools.generateImage({
4
  prompt: "A mountain at sunrise",
5
});
6
7
const response = await pollExecutedTool(client, toolExecutionId);
8
9
if (response.status === "succeeded") {
10
  console.log("File id:", response.results[0].fileId);
11
}

1
async function pollExecutedTool(
2
  client: Pick<VideoGenApiClient, "tools">,
3
  toolExecutionId: string,
4
  options?: { pollIntervalMs?: number; signal?: AbortSignal },
5
): Promise<ExecutedTool> {
6
  const pollIntervalMs = options?.pollIntervalMs ?? 1500;
7
8
  while (true) {
9
    options?.signal?.throwIfAborted();
10
    const executed = await client.tools.getToolExecutionInfo({ toolExecutionId });
11
12
    if (["succeeded", "failed", "cancelled"].includes(executed.status)) {
13
      return executed;
14
    }
15
16
    await new Promise((r) => setTimeout(r, pollIntervalMs));
17
  }
18
}