in lib/aws/active_job/sqs/executor.rb [72:80]
def _execute(message)
post_task(message)
rescue Concurrent::RejectedExecutionError
@task_complete.reset
@task_complete.wait
retry
end