Get a Kling model-route task

GET

tasks

cURL

task_id="<task_id>"

curl "https://api.cometapi.com/tasks?task_ids=${task_id}" \
  -H "Authorization: Bearer $COMETAPI_KEY"

import os
import requests

task_id = "<task_id>"
response = requests.get(
    "https://api.cometapi.com/tasks",
    params={"task_ids": task_id},
    headers={"Authorization": "Bearer " + os.environ["COMETAPI_KEY"]},
)
response.raise_for_status()
payload = response.json()
task = payload.get("data", payload)
if isinstance(task, list):
    task = task[0]
print(task["status"], task.get("outputs", []))

const taskId = "<task_id>";
const url = new URL("https://api.cometapi.com/tasks");
url.searchParams.set("task_ids", taskId);
const response = await fetch(url, {
  headers: { Authorization: `Bearer ${process.env.COMETAPI_KEY}` },
});
if (!response.ok) throw new Error(`HTTP ${response.status}`);
const payload = await response.json();
const data = payload.data ?? payload;
const task = Array.isArray(data) ? data[0] : data;
console.log(task.status, task.outputs ?? []);

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.cometapi.com/tasks",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.cometapi.com/tasks"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://api.cometapi.com/tasks")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "id": "<task_id>",
  "status": "submitted"
}

Use this endpoint after a Kling model-route creation request. Save data.id from the creation response and pass that ID as task_ids.

Request parameter

Parameter	Required	Description
`task_ids`	Yes	One task ID returned by a model-route creation request. Send one ID per request.

To retrieve one task, replace <task_id> with the data.id value from the creation response:

task_id="<task_id>"

curl "https://api.cometapi.com/tasks?task_ids=${task_id}" \
  -H "Authorization: Bearer $COMETAPI_KEY"

Immediately after creation, the response contains the submitted task:

{
  "id": "<task_id>",
  "status": "submitted"
}

Read the result

The response contains either a task object or a data array with one task. Read the task’s status. When it is succeeded, read the video URL from that task’s outputs array. An array response can also contain a top-level status; use the status inside data[0] for the selected task. A completed task has this response shape:

{
  "code": 0,
  "message": "SUCCEED",
  "status": "SUCCEEDED",
  "data": [
    {
      "id": "<task_id>",
      "status": "succeeded",
      "outputs": [
        {
          "type": "video",
          "url": "https://media.example.com/video.mp4",
          "duration": "5.041"
        }
      ]
    }
  ]
}

Field	Description
`id`	Task ID from the creation response.
`status`	Current task state. Continue querying until it reaches a terminal state.
`message`	Task detail returned when available.
`outputs[].type`	Output media type. Select an item with `type: video`.
`outputs[].url`	Video URL to download or store when the task succeeds.
`outputs[].duration`	Video duration in seconds when returned.

Store the finished video in your own storage if you need to retain it beyond the returned URL’s availability.

Authorizations

Authorization

string

header

required

Use your CometAPI API key as a Bearer token.

Query Parameters

task_ids

string

required

One task ID from the data.id field of a creation response.

Response

200 - application/json

Current state and available outputs for the requested task.

Option 1
Option 2

string

required

Task ID returned when the video task was created.

status

string

required

Task state, such as submitted, processing, succeeded, or failed.

message

string

Task detail when returned.

outputs

object[]

Generated media when the task returns outputs.

Show child attributes

create_time

integer

Task creation time in Unix milliseconds when returned.

update_time

integer

Last task update time in Unix milliseconds when returned.

Last modified on September 25, 2026

cURL

task_id="<task_id>"

curl "https://api.cometapi.com/tasks?task_ids=${task_id}" \
  -H "Authorization: Bearer $COMETAPI_KEY"

import os
import requests

task_id = "<task_id>"
response = requests.get(
    "https://api.cometapi.com/tasks",
    params={"task_ids": task_id},
    headers={"Authorization": "Bearer " + os.environ["COMETAPI_KEY"]},
)
response.raise_for_status()
payload = response.json()
task = payload.get("data", payload)
if isinstance(task, list):
    task = task[0]
print(task["status"], task.get("outputs", []))

const taskId = "<task_id>";
const url = new URL("https://api.cometapi.com/tasks");
url.searchParams.set("task_ids", taskId);
const response = await fetch(url, {
  headers: { Authorization: `Bearer ${process.env.COMETAPI_KEY}` },
});
if (!response.ok) throw new Error(`HTTP ${response.status}`);
const payload = await response.json();
const data = payload.data ?? payload;
const task = Array.isArray(data) ? data[0] : data;
console.log(task.status, task.outputs ?? []);

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.cometapi.com/tasks",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.cometapi.com/tasks"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://api.cometapi.com/tasks")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

{
  "id": "<task_id>",
  "status": "submitted"
}

Content moderation

API keys

Request parameter

Read the result

Authorizations

Query Parameters

Response

​Request parameter

​Read the result

Authorizations

Query Parameters

Response

Request parameter

Read the result