airflow.providers.vespa.triggers.vespa_feed_trigger¶

Classes¶

VespaFeedTrigger

Trigger that runs a Vespa feed, update, or delete operation.

Module Contents¶

class airflow.providers.vespa.triggers.vespa_feed_trigger.VespaFeedTrigger(docs, conn_info, operation_type='feed', feed_kwargs=None)[source]¶

Bases: airflow.triggers.base.BaseTrigger

Trigger that runs a Vespa feed, update, or delete operation.

docs[source]¶

conn_info[source]¶

operation_type = 'feed'[source]¶

feed_kwargs[source]¶

serialize()[source]¶

Serialize VespaFeedTrigger arguments and class path.

async run()[source]¶

Create the hook and execute the feed operation in the default executor.