@@ -285,7 +285,7 @@ Processing batches from SQS works in four stages:
285
285
@tracer.capture_lambda_handler
286
286
def lambda_handler(event, context: LambdaContext):
287
287
batch = event["Records"]
288
- with processor(records=batch, processor=processor ):
288
+ with processor(records=batch, handler=record_handler ):
289
289
processed_messages = processor.process() # kick off processing, return list[tuple]
290
290
291
291
return processor.response()
@@ -413,7 +413,7 @@ Processing batches from Kinesis works in four stages:
413
413
@tracer.capture_lambda_handler
414
414
def lambda_handler(event, context: LambdaContext):
415
415
batch = event["Records"]
416
- with processor(records=batch, processor=processor ):
416
+ with processor(records=batch, handler=record_handler ):
417
417
processed_messages = processor.process() # kick off processing, return list[tuple]
418
418
419
419
return processor.response()
@@ -549,7 +549,7 @@ Processing batches from Kinesis works in four stages:
549
549
@tracer.capture_lambda_handler
550
550
def lambda_handler(event, context: LambdaContext):
551
551
batch = event["Records"]
552
- with processor(records=batch, processor=processor ):
552
+ with processor(records=batch, handler=record_handler ):
553
553
processed_messages = processor.process() # kick off processing, return list[tuple]
554
554
555
555
return processor.response()
@@ -821,7 +821,7 @@ def record_handler(record: SQSRecord):
821
821
@tracer.capture_lambda_handler
822
822
def lambda_handler (event , context : LambdaContext):
823
823
batch = event[" Records" ]
824
- with processor(records = batch, processor = processor ):
824
+ with processor(records = batch, handler = record_handler ):
825
825
processed_messages: List[Union[SuccessResponse, FailureResponse]] = processor.process()
826
826
827
827
for messages in processed_messages:
0 commit comments