class Multiwoven::Integrations::Source::WatsonxAi::Client

def prepare_config_and_payload(sync_config)
  config = sync_config.source.connection_specification
  connection_config = config.with_indifferent_access.tap do |conf|
    conf[:config][:timeout] ||= 30
    conf[:is_stream] ||= false
  end
  payload = sync_config.model.query
  [connection_config, payload]
end