execute_task

in lib/aws/active_job/sqs/executor.rb [87:99]


        def execute_task(message)
          job = JobRunner.new(message)
          @logger.info("Running job: #{job.id}[#{job.class_name}]")
          job.run
          message.delete
        rescue JSON::ParserError => e
          @logger.error "Unable to parse message body: #{message.data.body}. Error: #{e}."
        rescue StandardError => e
          handle_standard_error(e, job, message)
        ensure
          @task_complete.set
        end