* Support retries in _ConcurrentJobExecution. (310 & 311) * Default emit source buffer size to 8 (311)
0.8.7
Not secure
* Introduce an upper bound for aiohttp version. (307) * Fix SampleWindow step. (305) * Fix completion on error in concurrent execution step. (308)
0.8.6
Not secure
ML-1101: indicate there were no events by writing datetime.min
0.8.5
Not secure
- New Flow.to_dict implementation. - ML-1101: passing last written event only if something was actually written
0.8.4
Not secure
* ML-1223: Create stream automatically in StreamTarget if doesn't exist (297) * StreamTarget - convert non json serializable types to string (298) * ML-1217: Do not terminate flow on await result. (300)
0.8.3
Not secure
- ML-1142: Fix completion on error and reject emit after termination