Obtener un resultado de imagen de FLUX

GET

flux

get_result

cURL

curl "https://api.cometapi.com/flux/v1/get_result?id=<task_id>" \
  -H "Authorization: Bearer $COMETAPI_KEY"

import os
import time
import requests

task_id = "<task_id>"
headers = {"Authorization": "Bearer " + os.environ["COMETAPI_KEY"]}
failure_statuses = {
    "Error",
    "Failed",
    "Failure",
    "Task not found",
    "Request Moderated",
    "Content Moderated",
    "failed",
    "failure",
}

for _ in range(60):
    response = requests.get(
        "https://api.cometapi.com/flux/v1/get_result",
        params={"id": task_id},
        headers=headers,
        timeout=30,
    )
    response.raise_for_status()
    task = response.json()
    status = task.get("status")
    print(status)

    if status == "Ready":
        print(task["result"]["sample"])
        break
    if status in failure_statuses:
        raise RuntimeError(f"FLUX task failed: {status}")

    time.sleep(5)
else:
    raise TimeoutError("FLUX task did not finish in time")

const taskId = "<task_id>";
const headers = { Authorization: `Bearer ${process.env.COMETAPI_KEY}` };
const failureStatuses = new Set([
  "Error",
  "Failed",
  "Failure",
  "Task not found",
  "Request Moderated",
  "Content Moderated",
  "failed",
  "failure",
]);

for (let attempt = 0; attempt < 60; attempt += 1) {
  const response = await fetch(
    `https://api.cometapi.com/flux/v1/get_result?id=${encodeURIComponent(taskId)}`,
    { headers, signal: AbortSignal.timeout(30_000) },
  );
  if (!response.ok) throw new Error(await response.text());

  const task = await response.json();
  console.log(task.status);

  if (task.status === "Ready") {
    console.log(task.result.sample);
    break;
  }
  if (failureStatuses.has(task.status)) {
    throw new Error(`FLUX task failed: ${task.status}`);
  }
  if (attempt === 59) throw new Error("FLUX task did not finish in time");

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

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.cometapi.com/flux/v1/get_result",
  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/flux/v1/get_result"

	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/flux/v1/get_result")

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": "Pending",
  "result": null
}

Descripción general

Pasa la tarea de nivel superior id devuelta por POST /flux/v1/\{model\} como el parámetro de consulta id. Sigue realizando sondeos dentro de un tiempo de espera limitado del cliente hasta que la tarea se complete correctamente o falle.

Estado	Acción del cliente
`Ready`	Lee `result.sample` y luego descarga o transfiere la imagen de inmediato.
`Error`, `Failed`, o `Failure`	Detén el proceso y muestra el error de la tarea.
`Task not found`	Detén el proceso; el ID es desconocido o ya no está disponible.
`Request Moderated`	Detén el proceso; la solicitud fue rechazada por moderación.
`Content Moderated`	Detén el proceso; el contenido generado fue rechazado por moderación.
Cualquier otro estado	Sigue realizando sondeos hasta que se alcance el tiempo de espera del cliente.

El resultado correcto puede incluir sample, seed, prompt y start_time. Se pueden omitir algunos campos, así que exige result.sample solo después de que la tarea esté Ready.

result.sample es temporal. No uses una URL de resultado del proveedor como un recurso duradero de la aplicación.

Autorizaciones

Authorization

string

header

requerido

Bearer token authentication. Use your CometAPI key.

Parámetros de consulta

string

requerido

Top-level task ID returned by the FLUX create endpoint.

Respuesta

200 - application/json

Current FLUX task state and, when ready, the generated image result.

string

requerido

FLUX task ID.

status

string

requerido

Task state. Ready is successful. Known failure states include Error, Failed, Failure, Task not found, Request Moderated, and Content Moderated.

result

object | null

Generation result. It can be null or omitted while the task is still running.

Show child attributes

progress

number | null

Task progress when returned.

details

any

Additional task details when returned.

preview

any

Task preview data when returned.

Última modificación el 31 de julio de 2026

cURL

curl "https://api.cometapi.com/flux/v1/get_result?id=<task_id>" \
  -H "Authorization: Bearer $COMETAPI_KEY"

import os
import time
import requests

task_id = "<task_id>"
headers = {"Authorization": "Bearer " + os.environ["COMETAPI_KEY"]}
failure_statuses = {
    "Error",
    "Failed",
    "Failure",
    "Task not found",
    "Request Moderated",
    "Content Moderated",
    "failed",
    "failure",
}

for _ in range(60):
    response = requests.get(
        "https://api.cometapi.com/flux/v1/get_result",
        params={"id": task_id},
        headers=headers,
        timeout=30,
    )
    response.raise_for_status()
    task = response.json()
    status = task.get("status")
    print(status)

    if status == "Ready":
        print(task["result"]["sample"])
        break
    if status in failure_statuses:
        raise RuntimeError(f"FLUX task failed: {status}")

    time.sleep(5)
else:
    raise TimeoutError("FLUX task did not finish in time")

const taskId = "<task_id>";
const headers = { Authorization: `Bearer ${process.env.COMETAPI_KEY}` };
const failureStatuses = new Set([
  "Error",
  "Failed",
  "Failure",
  "Task not found",
  "Request Moderated",
  "Content Moderated",
  "failed",
  "failure",
]);

for (let attempt = 0; attempt < 60; attempt += 1) {
  const response = await fetch(
    `https://api.cometapi.com/flux/v1/get_result?id=${encodeURIComponent(taskId)}`,
    { headers, signal: AbortSignal.timeout(30_000) },
  );
  if (!response.ok) throw new Error(await response.text());

  const task = await response.json();
  console.log(task.status);

  if (task.status === "Ready") {
    console.log(task.result.sample);
    break;
  }
  if (failureStatuses.has(task.status)) {
    throw new Error(`FLUX task failed: ${task.status}`);
  }
  if (attempt === 59) throw new Error("FLUX task did not finish in time");

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

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.cometapi.com/flux/v1/get_result",
  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/flux/v1/get_result"

	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/flux/v1/get_result")

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": "Pending",
  "result": null
}

Moderación de contenido

Claves API

Obtener un resultado de imagen de FLUX

Descripción general

Autorizaciones

Parámetros de consulta

Respuesta

​Descripción general

Autorizaciones

Parámetros de consulta

Respuesta

Descripción general