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