FivetranTrigger

Fivetran

FivetranTrigger is fired as deferred class with params to run the task in trigger worker

Access Instructions

Install the Fivetran provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

task_idReference to task id of the Dag
connector_idReference to the Fivetran connector id being used
fiventran_conn_idReference to Fivetran connection id
previous_completed_atThe last time the connector ran, collected on Sensor initialization.
xcomIf used, FivetranSensorAsync receives timestamp of previously completed sync
poke_intervalpolling period in seconds to check for the status

Documentation

FivetranTrigger is fired as deferred class with params to run the task in trigger worker

Was this page helpful?