class Multiwoven::Integrations::Source::Redshift::Client

def create_connection(connection_config)
  raise "Unsupported Auth type" unless connection_config[:credentials][:auth_type] == "username/password"
  PG.connect(
    host: connection_config[:host],
    dbname: connection_config[:database],
    user: connection_config[:credentials][:username],
    password: connection_config[:credentials][:password],
    port: connection_config[:port]
  )
end