scherand

Using partition "breaks" program logic

2

I am struggling to use `partition` in a pipeline because it "breaks" the logic of my program; presumably because it introduces asynchronous processing. As a simplified example, I have something...

According to the documentation of `accumulate` ([Accumulating State](https://streamz.readthedocs.io/en/latest/core.html#accumulating-state)), it is possible to not have `accumulate` "output" anything: > One piece of data comes in, either one or zero pieces go...