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.