Source code for lambda_handlers.start_job_handler

from __future__ import unicode_literals, print_function
from manager.manager import TxManager
from lambda_handlers.handler import Handler


class StartJobHandler(Handler):

    def _handle(self, event, context):
        """
        :param dict event:
        :param context:
        """
        for record in event['Records']:
            if record['eventName'] == 'INSERT' and 'job_id' in record['dynamodb']['Keys']:
                ddbARN = record['eventSourceARN']
                ddbTable = ddbARN.split(':')[5].split('/')[1]
                env_vars = {'job_table_name': ddbTable}
                job_id = record['dynamodb']['Keys']['job_id']['S']
                TxManager(**env_vars).start_job(job_id)