Dagster & Hightouch

With this integration you can trigger Hightouch syncs and monitor them from within Dagster. Fine-tune when Hightouch syncs kick-off, visualize their dependencies, and monitor the steps in your data activation workflow.

This native integration helps your team more effectively orchestrate the last mile of data analytics—bringing that data from the warehouse back into the SaaS tools your business teams live in. With the dagster-hightouch integration, Hightouch users have more granular and sophisticated control over when data gets activated.

Installation

pip install dagster-hightouch

Example

import os

from dagster_hightouch.ops import hightouch_sync_op
from dagster_hightouch.resources import ht_resource

import dagster as dg

HT_ORG = "39619"

run_ht_sync_orgs = hightouch_sync_op.configured(
    {"sync_id": HT_ORG}, name="hightouch_sfdc_organizations"
)


@dg.job
def ht_sfdc_job():
    ht_orgs = run_ht_sync_orgs()


defs = dg.Definitions(
    jobs=[ht_sfdc_job],
    resources={
        "hightouch": ht_resource.configured(
            {"api_key": dg.EnvVar("HIGHTOUCH_API_KEY")},
        ),
    },
)

About Hightouch

Hightouch syncs data from any data warehouse into popular SaaS tools that businesses run on. Hightouch uses the power of Reverse ETL to transform core business applications from isolated data islands into powerful integrated solutions.