def create()

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)