Consultar estado de job batch

curl --request GET \
  --url http://api.gu1.ai/batch-import/jobs/{jobId} \
  --header 'Authorization: Bearer <token>'

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('http://api.gu1.ai/batch-import/jobs/{jobId}', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "http://api.gu1.ai/batch-import/jobs/{jobId}",
  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 := "http://api.gu1.ai/batch-import/jobs/{jobId}"

	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("http://api.gu1.ai/batch-import/jobs/{jobId}")

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

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

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

{
  "success": true,
  "job.jobId": "<string>",
  "job.kind": "<string>",
  "job.status": "<string>",
  "job.totalItems": {},
  "job.succeeded": {},
  "job.failed": {},
  "job.skipped": {},
  "job.heartbeatAt": {},
  "job.leaseExpiresAt": {},
  "job.workerError": {},
  "job.createdAt": "<string>",
  "job.completedAt": {},
  "job.metadata": {},
  "job.jobFailure": {}
}

GET

batch-import

jobs

{jobId}

Consultar estado de job batch

curl --request GET \
  --url http://api.gu1.ai/batch-import/jobs/{jobId} \
  --header 'Authorization: Bearer <token>'

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('http://api.gu1.ai/batch-import/jobs/{jobId}', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "http://api.gu1.ai/batch-import/jobs/{jobId}",
  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 := "http://api.gu1.ai/batch-import/jobs/{jobId}"

	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("http://api.gu1.ai/batch-import/jobs/{jobId}")

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

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

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

{
  "success": true,
  "job.jobId": "<string>",
  "job.kind": "<string>",
  "job.status": "<string>",
  "job.totalItems": {},
  "job.succeeded": {},
  "job.failed": {},
  "job.skipped": {},
  "job.heartbeatAt": {},
  "job.leaseExpiresAt": {},
  "job.workerError": {},
  "job.createdAt": "<string>",
  "job.completedAt": {},
  "job.metadata": {},
  "job.jobFailure": {}
}

Endpoint

GET https://api.gu1.ai/batch-import/jobs/{jobId}

Usen esta ruta como endpoint canónico de polling después de cualquier upload bulk que devuelva 202 con un jobId. Resuelve el tipo de job automáticamente y hace lookup directo — no recorre el histórico completo.

Autenticación

Authorization: Bearer YOUR_API_KEY

Requiere al menos uno de: transactions:create, entities:bulk_import, events:create.

Query parameters

Parámetro	Descripción
`include`	Lista CSV opcional. Usen `include=failures` para obtener el mismo JSON que el endpoint de failures por tipo (`failures[]`, `skips[]` en entidades, etc.). Omitan para un payload liviano durante el polling.

Respuestas HTTP

Status	Cuándo
`200`	Job encontrado
`401`	No autenticado
`403`	Sin permiso de batch-import
`404`	`jobId` desconocido o job de otra organización

Flujo de polling recomendado

Upload (entidades, transacciones o user events) → guardar jobId del 202.
Poll GET /batch-import/jobs/{jobId} cada 2–5 segundos.
Detener cuando status sea terminal: completed, failed, cancelled o interrupted.
Si necesitan detalle fila a fila, llamar con ?include=failures o usar el endpoint de failures por tipo (ver Bulk imports overview).

Para listar jobs recientes (estilo dashboard), usen Unified history. Para polling de un job puntual, preferir este endpoint.

JSON (default — solo status)

{
  "success": true,
  "job": {
    "jobId": "550e8400-e29b-41d4-a716-446655440000",
    "kind": "entity_batch",
    "status": "running",
    "totalItems": 100,
    "succeeded": 45,
    "failed": 2,
    "skipped": 1,
    "heartbeatAt": "2026-06-26T12:00:00.000Z",
    "leaseExpiresAt": "2026-06-26T12:10:00.000Z",
    "workerError": null,
    "createdAt": "2026-06-26T11:59:00.000Z",
    "completedAt": null,
    "metadata": { "fileName": "entities.csv" }
  }
}

boolean

Siempre true cuando el job existe.

string

Identificador del job devuelto en el upload.

string

entity_batch (alias entity_automatic), transaction_batch o user_event_batch.

string

queued, running, completed, failed, cancelled o interrupted. Durante una cancelación puede seguir en running con metadata.batchCancelRequested.

number | null

Total de filas/ítems del job.

number | null

Cantidad procesada con éxito.

number | null

Cantidad de filas fallidas.

number | null

Cantidad omitida (p. ej. taxId duplicado en entidades).

string | null

Último heartbeat del worker (ISO 8601).

string | null

Expiración del lease del worker (ISO 8601).

string | null

Error del worker truncado cuando el job falló a nivel job.

string

Creación del job (ISO 8601).

string | null

Finalización cuando es terminal (ISO 8601).

object | null

Metadata del job (p. ej. fileName, modo de import).

object | null

Presente cuando status es failed y abortó el job completo. Incluye code estable y message — ver Failure codes.

JSON con `?include=failures`

Mismo contrato que los endpoints JSON de failures por tipo:

Entidades: Entity batch failures
Transacciones: Transaction batch failures
User events: User-event batch failures

Sin fallos por fila, failures es un array vacío (failuresTotal: 0). Ver también: Bulk imports overview, Unified history.

⌘I

Comenzando

SDK

Casos de Uso

Webhooks

Workflows

Monitoreo (entidades)

Persona

Mensajería

Empresa

Dispositivos

Eventos

Conozca Su Cliente (KYC)

Transacciones

Métodos de Pago

Reglas

Listas personalizadas

Matriz de Riesgo

Alertas

Investigaciones

Ingesta de Datos

Importaciones masivas

Documentos

Enriquecimiento

AML Crypto

Servicios

Integraciones

Tutoriales Interactivos

Consultar estado de job batch

Endpoint

Autenticación

Query parameters

Respuestas HTTP

Flujo de polling recomendado

JSON (default — solo status)

JSON con `?include=failures`

​Endpoint

​Autenticación

​Query parameters

​Respuestas HTTP

​Flujo de polling recomendado

​JSON (default — solo status)

​JSON con ?include=failures

Endpoint

Autenticación

Query parameters

Respuestas HTTP

Flujo de polling recomendado

JSON (default — solo status)

JSON con `?include=failures`