in sync/datahub/bigquery_etl_source.py [0:0]
def create(cls, config_dict: dict, ctx: PipelineContext) -> "BigQueryEtlSource": config = BigQueryEtlSourceConfig.parse_obj(config_dict) return cls(config, ctx)