Skip to content

pystorm 3.1.0
Compare
Choose a tag to compare
@dan-blanchard dan-blanchard released this 26 Jan 21:06
· 18 commits to master since this release
v3.1.0
d013631
This commit was signed with the committer’s verified signature.
dan-blanchard Dan Blanchard
GPG key ID: 293926F6EE60F67B
Learn about vigilant mode.

Features

  • Added a ReliableSpout implementation that can be used to have spouts that will automatically replay failed tuples up to a specified number of times before giving up on them. (PR #39)
  • Added Spout.activate and Spout.deactivate methods that will be called in Storm 1.1.0 and above when a spout is activated or deactivated. This is handy if you want to close database connections on deactivation and reconnect on activation. (Issue #41, PR #42)

Fixes

  • Fixed an issue where batching bolts would fail all batches they had received when they encountered an exception, even when exit_on_exception was False. Now they will only fail the current batch when exit_on_exception is False; if it is True, all batches are still failed. (PR #43)
Assets 2
Loading