Description

This would happen when a StreamProducer is closed and there are no objects in the current batch buffer. A lot of connector implementations, such as the ones used to test the StreamProducer, are okay with put_batch([]) but the RedisConnector raises an error here. Maybe in the future we should support empty batches in put_batch() as a part of the Connector protocol, but it is definitely not needed to call put_batch in the StreamProducer in this case.

Fixes N/A

Type of Change

• Breaking Change (fix or enhancement which changes existing semantics of the public interface)
• Enhancement (new features or improvements to existing functionality)
• Bug (fixes for a bug or issue)
• Internal (refactoring, style changes, testing, optimizations)
• Documentation update (changes to documentation or examples)
• Package (dependencies, versions, package metadata)
• Development (CI workflows, pre-commit, linters, templates)
• Security (security related changes)

Testing

All test pass and verified the fix solved the problem in the benchmark suite that I ran into with Redis.

Pull Request Checklist

• I have read the Contributing and PR submission guides.

Please confirm the PR meets the following requirements.

• Tags added to PR (e.g., breaking, bug, enhancement, internal, documentation, package, development, security).
• Code changes pass pre-commit (e.g., mypy, ruff, etc.).
• Tests have been added to show the fix is effective or that the new feature works.
• New and existing unit tests pass locally with the changes.
• Docs have been updated and reviewed if relevant.