Sha256: e053d3c5f4de4244db09febb85d8df8f103d56cc7ea6476c12eab8e4744e2bac
Contents?: true
Size: 905 Bytes
Versions: 18
Compression:
Stored size: 905 Bytes
Contents
# frozen_string_literal: true
require 'active_job'
module PlatformSdk
module Jobs
class SendNounToPipelineJob < ActiveJob::Base
queue_as :default
def perform(message, one_roster_message)
send_to_pipeline(message, one_roster_message)
end
private
def send_to_pipeline(message, one_roster_message)
credentials = {
pipeline_host: ENV.fetch('DATA_PIPELINE_HOST', 'stage-di-data-pipeline-api.strongmind.com'),
pipeline_username: ENV.fetch('DATA_PIPELINE_USERNAME', 'canvas_prod'),
pipeline_password: ENV.fetch('DATA_PIPELINE_PASSWORD', '')
}
client = PlatformSdk::DataPipeline::Client.new(credentials)
client.post(message) unless Rails.env.development?
return unless one_roster_message.present? && !Rails.env.development?
client.post(one_roster_message)
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems