Skip to content

Commit c74811b

Browse files
authored
feat(batch): new BatchProcessor for SQS, DynamoDB, Kinesis (#886)
1 parent 5362a16 commit c74811b

File tree

8 files changed

+2129
-160
lines changed

8 files changed

+2129
-160
lines changed

Diff for: .pre-commit-config.yaml

-4
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,6 @@ repos:
1111
- id: trailing-whitespace
1212
- id: end-of-file-fixer
1313
- id: check-toml
14-
- repo: https://github.com/pre-commit/pygrep-hooks
15-
rev: v1.5.1
16-
hooks:
17-
- id: python-use-type-annotations
1814
- repo: local
1915
hooks:
2016
- id: black

Diff for: aws_lambda_powertools/utilities/batch/__init__.py

+21-3
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,25 @@
44
Batch processing utility
55
"""
66

7-
from .base import BasePartialProcessor, batch_processor
8-
from .sqs import PartialSQSProcessor, sqs_batch_processor
7+
from aws_lambda_powertools.utilities.batch.base import (
8+
BasePartialProcessor,
9+
BatchProcessor,
10+
EventType,
11+
ExceptionInfo,
12+
FailureResponse,
13+
SuccessResponse,
14+
batch_processor,
15+
)
16+
from aws_lambda_powertools.utilities.batch.sqs import PartialSQSProcessor, sqs_batch_processor
917

10-
__all__ = ("BasePartialProcessor", "PartialSQSProcessor", "batch_processor", "sqs_batch_processor")
18+
__all__ = (
19+
"BatchProcessor",
20+
"BasePartialProcessor",
21+
"ExceptionInfo",
22+
"EventType",
23+
"FailureResponse",
24+
"PartialSQSProcessor",
25+
"SuccessResponse",
26+
"batch_processor",
27+
"sqs_batch_processor",
28+
)

0 commit comments

Comments
 (0)