Class: Core::Jobs::Producer

Inherits:
Object
  • Object
show all
Defined in:
lib/core/jobs/producer.rb

Constant Summary collapse

JOB_TYPES = 
%i(sync).freeze

Class Method Summary collapse

Class Method Details

.enqueue_job(job_type:, connector_settings:) ⇒ Object

Raises:



18
19
20
21
22
23
 
# File 'lib/core/jobs/producer.rb', line 18

def enqueue_job(job_type:, connector_settings:)
  raise UnsupportedJobType unless JOB_TYPES.include?(job_type)
  raise ArgumentError unless connector_settings.kind_of?(ConnectorSettings)

  ElasticConnectorActions.create_job(connector_settings: connector_settings)
end