Saltar a contenido

Artifacts

2 endpoint(s)


GET /api/v1/dags/{dag_id}/runs/{date}/{run_id}/artifacts

List all artifacts for a run

Lists every .parquet file under the run with size, mtime and 5-minute presigned URLs. Use this when the consumer wants to enumerate or batch-download.

Autenticación

Bearer Token requerido. El id_company se extrae automáticamente del token.

Parámetros de ruta

Parámetro Tipo Requerido Default Descripción
dag_id string DAG/ETL UUID
date string Run partition date (YYYY-MM-DD)
run_id string Airflow run_id (URL-encoded)

Respuestas

Código Descripción
200 List of artifacts — RunArtifactsResponse
401 Unauthorized — ErrorResponse
502 S3 storage error — ErrorResponse
422 Validation Error — HTTPValidationError

GET /api/v1/dags/{dag_id}/runs/{date}/{run_id}/artifacts/{artifact_kind}

Presigned URL for one artifact

Returns a presigned URL for a specific artifact (default TTL 5 min). artifact_kind is <phase>-<name> (e.g. extract-data) or event-{queue-data,event}. Chunked artifacts (data/logs/errors) default to chunk 0 — use ?chunk=N for others.

Autenticación

Bearer Token requerido. El id_company se extrae automáticamente del token.

Parámetros de ruta

Parámetro Tipo Requerido Default Descripción
dag_id string DAG/ETL UUID
date string Run partition date (YYYY-MM-DD)
run_id string Airflow run_id (URL-encoded)
artifact_kind string kebab-case artifact identifier (e.g. extract-data, event-queue-data)

Query parameters

Parámetro Tipo Requerido Default Descripción
attempt integer 1 Phase attempt number (1-based)
chunk integer 0 Chunk index for chunked artifacts (data/logs/errors)
expires_in integer 300 Presigned URL TTL in seconds

Respuestas

Código Descripción
200 Presigned URL generated — PresignedUrlResponse
401 Unauthorized — ErrorResponse
404 Artifact not found in S3 — ErrorResponse
422 Unknown artifact kind — ErrorResponse
502 S3 error — ErrorResponse