Class: Jets::Job::Base
Instance Attribute Summary
#context, #event, #meth
Class Method Summary
collapse
#sqs_event_payload
#sns_event_payload
#s3_event, #s3_object
#log_event
#kinesis_data
#_normalize_options, _prefixes, abstract!, inherited, #initialize, #logger, output_keys, subclasses
#lambda_functions
Class Method Details
35
36
37
38
39
40
41
42
43
44
|
# File 'lib/jets/job/base.rb', line 35
def perform_later(meth, event={}, context={})
if on_lambda?
function_name = "#{self.to_s.underscore}-#{meth}"
call = Jets::Commands::Call::Caller.new(function_name, JSON.dump(event), invocation_type: "Event")
call.run
else
Jets.logger.info "INFO: Not on AWS Lambda. In local mode perform_later executes the job with perform_now instead."
perform_now(meth, event, context)
end
end
|
31
32
33
|
# File 'lib/jets/job/base.rb', line 31
def perform_now(meth, event={}, context={})
process(event, context, meth)
end
|
.process(event, context, meth) ⇒ Object
26
27
28
29
|
# File 'lib/jets/job/base.rb', line 26
def process(event, context, meth)
job = new(event, context, meth)
job.send(meth)
end
|