v0.8.9

• Fix documentation.
• Update pyarrow and numpy versions requirements

v0.8.8

• Support retries in _ConcurrentJobExecution. (#310 & #311)
• Default emit source buffer size to 8 (#311)

v0.8.7

• Introduce an upper bound for aiohttp version. (#307)
• Fix SampleWindow step. (#305)
• Fix completion on error in concurrent execution step. (#308)

v0.8.6

ML-1101: indicate there were no events by writing datetime.min

v0.8.5

• New Flow.to_dict implementation.
• ML-1101: passing last written event only if something was actually written

v0.8.4

• 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)

v0.8.3

• ML-1142: Fix completion on error and reject emit after termination

v0.8.2

• ML-686: v3io_driver support for parallel array operations

v0.8.1

• Fix S3 URL parsing and S3 integration tests.
• Fix error on keyless (nuclio) event.
• ML-1147: Fix ever-growing traceback.
• Refactor table's persist to persist asynchronously before advancing fixed windows

v0.8.0

• ML-887: Always write outstanding streaming records when worker is idle