airflow.providers.vespa.operators.vespa_ingest¶

Classes¶

VespaIngestOperator

Defer a Vespa feed, update, or delete operation to a trigger.

Module Contents¶

class airflow.providers.vespa.operators.vespa_ingest.VespaIngestOperator(*, docs, vespa_conn_id='vespa_default', operation_type='feed', feed_kwargs=None, **kwargs)[source]¶

Bases: airflow.providers.common.compat.sdk.BaseOperator

Defer a Vespa feed, update, or delete operation to a trigger.

template_fields: collections.abc.Sequence[str] = ('docs', 'vespa_conn_id')[source]¶

docs[source]¶

vespa_conn_id = 'vespa_default'[source]¶

operation_type = 'feed'[source]¶

feed_kwargs[source]¶

execute(context)[source]¶

Resolve the Vespa connection in the worker and defer ingestion to a trigger.

execute_complete(context, event)[source]¶

Return a compact success payload or raise on trigger failure.