class Multiwoven::Integrations::Source::Bigquery::Client

def create_connection(connection_config)
  Google::Cloud::Bigquery.new(
    project: connection_config["project_id"],
    credentials: connection_config["credentials_json"]
  )
end