def create_function3_trigger()

in workflow1_endpointbuilder/sam-app/functions/function1_createtableandfunction3trigger/index.py [0:0]

• 15 lines of code
• 1 McCabe index (conditional complexity)

def create_function3_trigger(stream_arn):
    lambda_client = boto3.client('lambda')
    lambda_client.create_event_source_mapping(
        EventSourceArn=stream_arn,
        FunctionName='EndpointBuilder-Function3-ProcessObjects',
        Enabled=True,
        BatchSize=1000,
        ParallelizationFactor=10,
        StartingPosition='TRIM_HORIZON',
        BisectBatchOnFunctionError=True,
        MaximumRetryAttempts=3,
        FunctionResponseTypes=[
            'ReportBatchItemFailures',
        ]
    )