shrivardhan
shrivardhan
# Summary MapHandler parameters such as `keys` needs to be documented. It would help to know their intent and few useful usage examples. https://pkg.go.dev/github.com/numaproj/numaflow-go/pkg/[email protected]#MapHandler # Use Cases As I'm exploring...
Integrate sqs source with controller. Fixes #2390 and #2368 - add support for all sqs configs - support different ways to authenticate Note: pending use Initialism
update allowed python version
## SQS Source: `readTimeout` incorrectly overrides `waitTimeSeconds` config **Problem**: The SQS source derives `wait_time_seconds` from Numaflow's `readTimeout` on each SQS call, completely ignoring the user-configured `waitTimeSeconds`. Since `readBatchSize` often requires...
# Summary What change needs making? # Use Cases When would you use this? --- **Message from the maintainers**: If you wish to see this enhancement implemented please add a...
- verify that passing a empty message with no watermark, generates an output with watermark equal to UTC 0.