Skip to content

Conversation

@HarshCasper
Copy link
Member

No description provided.

- Support for wildcards (`*`) in JSONPath in input transformation is not implemented.
- Lack of concurrency support (i.e., ParallelizationFactor), resulting in slower processing in high-throughput scenarios.
- Lack of lifecycle management for pipe states (i.e., missing tests for state transitions).
- Lack of re-sharding support when polling from Kinesis and DynamoDB streams.
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Perhaps we can rather phrase this as "limited support", since we do have re-sharding functionality... it's just rough around the edges 😅

- Lack of concurrency support (i.e., ParallelizationFactor), resulting in slower processing in high-throughput scenarios.
- Lack of lifecycle management for pipe states (i.e., missing tests for state transitions).
- Lack of re-sharding support when polling from Kinesis and DynamoDB streams.
- Batch handling behavior may have parity issues (e.g., batch flushing rules by size, length, time, etc. are not implemented).
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We handle batching and have quite a few parity tests AFAIK 🤔 Unsure if it's worth mentioning this here.

See the ESM docs https://docs.localstack.cloud/aws/services/lambda/#behaviour-coverage (the pipes implementation is based off of the ESM one).

Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@gregfurman this line used to be in the docs before. This PR's change only clarifies input transformation. If batch behavior is not described correctly I'd suggest to raise a separate docs ticket about it and clarify batching behavior there, without blocking this PR.

- Lack of concurrency support (i.e., ParallelizationFactor), resulting in slower processing in high-throughput scenarios.
- Lack of lifecycle management for pipe states (i.e., missing tests for state transitions).
- Lack of re-sharding support when polling from Kinesis and DynamoDB streams.
- Batch handling behavior may have parity issues (e.g., batch flushing rules by size, length, time, etc. are not implemented).
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@gregfurman this line used to be in the docs before. This PR's change only clarifies input transformation. If batch behavior is not described correctly I'd suggest to raise a separate docs ticket about it and clarify batching behavior there, without blocking this PR.

@gregfurman gregfurman dismissed their stale review October 23, 2025 16:46

Misha addressed feedback

@remotesynth remotesynth merged commit aeed8e8 into main Oct 23, 2025
1 check passed
@remotesynth remotesynth deleted the pipes-target-input-transformation branch October 23, 2025 18:10
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

6 participants