search

WallarooLabs / wally

Distributed Stream Processing
https://www.wallaroolabs.com
Apache License 2.0
1.48k stars 69 forks source link

aloc_sink: avoid exception when _worker_name is None #3111

Closed slfritchie closed 4 years ago

slfritchie commented 4 years ago

Robustify aloc_sink by avoiding exception crashes when self._worker_name is None.

jtfmumm commented 4 years ago

@slfritchie There's a failing ci test. If that's spurious, then this can be merged.

slfritchie commented 4 years ago

This rebase onto today's master will use the fix for #3112 and thus fix the intermittent conformance test failure.