Skip to content

Commit 7a1b43a

Browse files
committed
Let's see how destinations handles a list of objects being returned
1 parent 8e9c5b8 commit 7a1b43a

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

src/handlers/TransformS3BucketEventToEntity/function.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -174,9 +174,8 @@ def _main(event_detail: S3BucketEventDetail) -> Entity:
174174
return entity
175175

176176

177-
@LOGGER.inject_lambda_context
178177
@event_source(data_class=S3BucketEvent)
179-
def handler(event: S3BucketEvent, _: LambdaContext) -> Entity:
178+
def handler(event: S3BucketEvent, _: LambdaContext) -> List[Entity]:
180179
'''Event handler'''
181180
LOGGER.debug('Event', extra={"message_object": event})
182181
entity = _main(
@@ -185,4 +184,4 @@ def handler(event: S3BucketEvent, _: LambdaContext) -> Entity:
185184

186185
LOGGER.debug('Output', extra={"message_object": json.dumps(entity)})
187186

188-
return entity
187+
return [ entity, entity, entity, entity, entity ]

0 commit comments

Comments
 (0)