Back to integrations
Dagster + Census

Dagster Integration:
Dagster + Census

Trigger Census synchs from within your Dagster pipelines.

About this integration

With the dagster-census integration you can execute a Census sync and poll until that sync completes, raising an error if it is unsuccessful.

Installation

pip install dagster-census

Example

import dagster as dg
from dagster_census import CensusResource


@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.


Community / Partner integration:

This integration was built and is maintained by a community user or a technology partner from outside of Dagster Labs.