satorbis_kit.pgstac.clients.airflow module

STAC-specific Airflow client wrapper.

class satorbis_kit.pgstac.clients.airflow.AirflowSTACClient(base_url: str, username: str, password: str)

Bases: AbstractSTACClient

Client for STAC ingestion operations using Airflow.

This class wraps the generic AirflowClient and provides STAC-specific functionality for submitting and tracking STAC ingestion jobs.

airflow_client

Generic Airflow client for API communication

dag_id

DAG identifier for STAC ingestion

DAG_ID = 'stac_item_batch_creation_dag'

get_job_status(job_id: str) → Dict[str, Any]

Get status of an ingestion job.

Parameters:

job_id – Job ID returned from submit_ingestion

Returns:

Dictionary with job status information

Raises:

APIError – If API request fails

submit_ingestion(config: IngestionConfig) → IngestionResponse

Submit raster stacking and STAC ingestion request.

Parameters:

config – IngestionConfig object with job parameters

Returns:

IngestionResponse with job ID and status

Raises:

APIError – If API request fails