Overview
Setup
Create an API Token

Add the Airflow connection
hightouch_default
and set the host to https://api.hightouch.io
.
Find the Sync ID

Install the Airflow package
pip install airflow-provider-hightouch
Add the HightouchTriggerSyncOperator to your DAG
from airflow_provider_hightouch.operators.hightouch \
import HightouchTriggerSyncOperator
with DAG(....) as dag:
...
# This task will submit the request but not wait for completion of the
# sync before completing.
my_async_task = HightouchTriggerSyncOperator(
task_id="run_my_sync", sync_id=1234
)
# This task will wait for the sync status to complete or error before
# completing. Warnings can be treated as errors or successes depending
# on your use case.
my_sync_task = HightouchTriggerSyncOperator(
task_id="run_sync", sync_id=123, synchronous=True, error_on_warning=True
)
- Connection issues with your data warehouse?
- Confusing API responses from destination systems?
- Unsupported destination objects or modes?
- Help with complex SQL queries?
Need help?
Our team is relentlessly focused on your success. We're ready to jump on a call to help unblock you.
or
Feature Requests?
If you see something that's missing from our app, let us know and we'll work with you to build it!
We want to hear your suggestions for new sources, destinations, and other features that would help you activate your data.