Module: PlatformSdk::ActiveRecord::DataPipelineable::ClassMethods

Defined in:
lib/platform_sdk/active_record/data_pipelineable.rb

Instance Method Summary collapse

Instance Method Details

#send_bulk_insert_to_pipeline(attributes_array, action: 'created') ⇒ Object 



81
82
83
84
85
86
87
 
# File 'lib/platform_sdk/active_record/data_pipelineable.rb', line 81

def send_bulk_insert_to_pipeline(attributes_array, action: 'created')
  attributes_array.each do |attributes|
    message = build_bulk_pipeline_payload(attributes, action)
    one_roster_message = build_bulk_one_roster_payload(attributes)
    Jobs::SendNounToPipelineJob.perform_later(message, one_roster_message)
  end
end