Skip to main content

Dagster & Census

With the Census integration you can execute a Census sync and poll until that sync completes, raising an error if it's unsuccessful.

Installation​

uv add dagster-census

Example​

from dagster_census import CensusResource

import dagster as dg


@dg.asset
def census_source(census: CensusResource):
    census.get_source(source_id=1)


defs = dg.Definitions(
    assets=[census_source],
    resources={"census": CensusResource(api_key=dg.EnvVar("CENSUS_API_KEY"))},
)

About Census​

Census syncs data from your cloud warehouse to the SaaS tools your organization uses. It allows everyone in your organization to take action with good data, no custom scripts or API integrations required.