HightouchTriggerSyncOperator
HightouchThis operator triggers a run for a specified Sync in Hightouch via the Hightouch API.
Access Instructions
Install the Hightouch provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
sync_idintID of the sync to trigger
sync_slugSlug of the sync to trigger
connection_idstrName of the connection to use, defaults to hightouch_default
api_versionstrHightouch API version. Only v3 is supported.
synchronousboolWhether to wait for the sync to complete before completing the task
error_on_warningboolShould sync warnings be treated as errors or ignored?
wait_secondsfloatTime to wait in between subsequent polls to the API.
timeoutintMaximum time to wait for a sync to complete before aborting
Documentation
This operator triggers a run for a specified Sync in Hightouch via the Hightouch API.
See also
For more information on how to use this operator, take a look at the guide: https://hightouch.io/docs/integrations/airflow/
Example DAGs
hightouch_trigger_sync
Data Processing
Using Hightouch for Reverse ETL in Airflow
An ELT pipeline which extracts Salesforce customer data to Snowflake for transformation and enrichment, and synced back to Salesforce via Hightouch.
DatabasesETL/ELTStorageBig Data & Analytics
Rerun dbt Models from Failure
This example shows how you can use the new `dbt build +=` command to rerun a model from the point of failure.
ETL/ELT