Source code for dagster_gcp.bigquery.resources

from google.cloud import bigquery  # type: ignore

from dagster import resource

from .configs import bq_resource_config


[docs]@resource(
    config_schema=bq_resource_config(), description="Dagster resource for connecting to BigQuery"
)
def bigquery_resource(context):
    return bigquery.Client(**context.resource_config)