From ee8cc78b942fb0ba963cd2392be924704b5fb4fa Mon Sep 17 00:00:00 2001 From: heitorlessa Date: Thu, 6 Jan 2022 09:53:39 +0100 Subject: [PATCH] docs(batch): fix typo in context manager keyword --- docs/utilities/batch.md | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/utilities/batch.md b/docs/utilities/batch.md index cdfb51549ae..6750704f9f1 100644 --- a/docs/utilities/batch.md +++ b/docs/utilities/batch.md @@ -285,7 +285,7 @@ Processing batches from SQS works in four stages: @tracer.capture_lambda_handler def lambda_handler(event, context: LambdaContext): batch = event["Records"] - with processor(records=batch, processor=processor): + with processor(records=batch, handler=record_handler): processed_messages = processor.process() # kick off processing, return list[tuple] return processor.response() @@ -413,7 +413,7 @@ Processing batches from Kinesis works in four stages: @tracer.capture_lambda_handler def lambda_handler(event, context: LambdaContext): batch = event["Records"] - with processor(records=batch, processor=processor): + with processor(records=batch, handler=record_handler): processed_messages = processor.process() # kick off processing, return list[tuple] return processor.response() @@ -549,7 +549,7 @@ Processing batches from Kinesis works in four stages: @tracer.capture_lambda_handler def lambda_handler(event, context: LambdaContext): batch = event["Records"] - with processor(records=batch, processor=processor): + with processor(records=batch, handler=record_handler): processed_messages = processor.process() # kick off processing, return list[tuple] return processor.response() @@ -821,7 +821,7 @@ def record_handler(record: SQSRecord): @tracer.capture_lambda_handler def lambda_handler(event, context: LambdaContext): batch = event["Records"] - with processor(records=batch, processor=processor): + with processor(records=batch, handler=record_handler): processed_messages: List[Union[SuccessResponse, FailureResponse]] = processor.process() for messages in processed_messages: