Syncs 12

- ▶ users_to_hubspot
- ▶ orders_to_pg
- ▶ alerts_to_slack
- ▶ accounts_to_hubspot
- ▶ subscriptions_to_stripe
- … 7 more

Sources 2

- ▶ bq_prod
- ▶ pg_replica

Destinations 3

- ▶ postgres (public.users)
- ▶ postgres (public.orders)
- ▶ slack (#alerts)

Tags 2

- # production
- # crm

Overview

# my-drt-project

Generated 2026-05-13 01:00 UTC · drt 0.8.0
12
syncs
2
sources
3
destinations

## Source types

bigquery
10
postgres
2

## Destination types

postgres
7
slack
3
hubspot
2

## Recent runs

Time (UTC) | Sync | Status | Rows | Duration
--- | --- | --- | --- | ---
23:55:12 | users_to_hubspot | ✓ success | 1,248 | 3.1s
23:00:48 | orders_to_pg | ⚠ partial | 502/520 | 6.4s
22:55:33 | alerts_to_slack | ✗ failed | — | 8.2s
22:00:11 | accounts_to_hubspot | ✓ success | 312 | 1.8s
21:55:50 | subscriptions_to_stripe | ✓ success | 89 | 2.3s

DAG

# Lineage

Filter:

    graph LR
        subgraph Sources
          src_bq[bq_prod]
        end
        subgraph Syncs
          sync_users{{users_to_hubspot
    upsert}}
          sync_orders{{orders_to_pg
    upsert}}
          sync_alerts{{alerts_to_slack
    full}}
        end
        subgraph Destinations
          dst_pg_users[postgres public.users]
          dst_pg_orders[postgres public.orders]
          dst_slack[slack #alerts]
        end
        src_bq -->|extract| sync_users
        src_bq -->|extract| sync_orders
        src_bq -->|extract| sync_alerts
        sync_users -->|load| dst_pg_users
        sync_orders -->|load| dst_pg_orders
        sync_alerts -->|load| dst_slack
        sync_users -.lookup.-> sync_orders

──▶ extract / load ┄┄▶ lookup (heuristic FK across syncs)
Syncs / users_to_hubspot

# users_to_hubspot

Sync users from BigQuery into HubSpot CRM, upserting by email.
# production # crm
Last run
2026-05-13 00:00 UTC · ✓ success
1,248 rows · 3.1s
Configuration
source: bq_prod · mode: upsert
schedule: 0 */4 * * *

    name: users_to_hubspot
    description: Sync users from BigQuery into HubSpot CRM, upserting by email.
    model: queries/users.sql
    tags: [production, crm]
    destination:
      type: hubspot
      object: contacts
      upsert_key: email
      auth:
        type: bearer
        token_env: HUBSPOT_TOKEN
    sync:
      mode: upsert
      batch_size: 100

## Lineage

Upstream

- source bq_prod

Downstream

- lookup orders_to_pg via lookups.user_id

Sources / bq_prod

# bq_prod

Type: bigquery · Profile resolved from drt_project.yml

## Consumed by 10 syncs

Sync | Query template | Mode | Destination
--- | --- | --- | ---
users_to_hubspot | queries/users.sql | upsert | hubspot (contacts)
orders_to_pg | queries/orders.sql | upsert | postgres (public.orders)
alerts_to_slack | queries/alerts.sql | full | slack (#alerts)
accounts_to_hubspot | queries/accounts.sql | upsert | hubspot (companies)

## Query templates referenced

- queries/users.sql
- queries/orders.sql
- queries/alerts.sql
- queries/accounts.sql
- … 6 more

Destinations / postgres (public.users)

# postgres (public.users)

Type: postgres · Endpoint resolved from PG_HOST_USERS env

## Produced by

Sync | Mode | Source
--- | --- | ---
users_to_hubspot | upsert | bq_prod

## Mode breakdown

upsert: 1

## Referenced by other syncs' lookups (FK)

- orders_to_pg — lookups.user_id → public.users