v0.2.0dev58

What's Changed

• Rabbitmq: Make rabbitmq more reliable by @isra17 in #173

Full Changelog: v0.2.0dev57...v0.2.0dev58

v0.2.0dev57

What's Changed

• dependencies: Upgrade ray, dev and aio-pika dependencies by @isra17 in #171

Full Changelog: v0.2.0dev56...0.2.0dev57

v0.2.0dev56

What's Changed

• ray: restart an ensure we never create over "count" actors by @isra17 in #167

Full Changelog: v0.2.0dev55...v0.2.0dev56

v0.2.0dev55

What's Changed

• RabbitMQTopic: handle invalid channel error by @aviau in #165
• RabbitMQTopic: handle errors by @isra17 in #166

Full Changelog: v0.2.0dev54...v0.2.0dev55

v0.2.0dev54

What's Changed

• ray: Do not set automatic restart of ray actor by @isra17 in #164

Full Changelog: v0.2.0dev53...v0.2.0dev54

v0.2.0dev53

What's Changed

• metrics: Add timing metrics by @isra17 in #161
• executor: Define concurrency only in Executor class by @isra17 in #163
• Set name to all create_task calls by @isra17 in #162

Full Changelog: v0.2.0dev52...v0.2.0dev53

v0.2.0dev52

What's Changed

• RabbitMQ backpressure by @isra17 in #160

Full Changelog: v0.2.0dev51...v0.2.0dev52

v0.2.0dev51

What's Changed

• worker_manager: Load definition from path instead of directory by @isra17 in #158
• assign need_reconnect before use by @infherny in #159

New Contributors

• @infherny made their first contribution in #159

Full Changelog: v0.2.0dev50...v0.2.0dev51

v0.2.0dev50

What's Changed

• topics: Add periodic topic by @isra17 in #157

Full Changelog: v0.2.0dev49...v0.2.0dev50

v0.2.0dev49

What's Changed

• worker_manager(config): raise on duplicate object by @aviau in #151
• metrics: Add metrics about resource used and outputs by @isra17 in #150
• ray: set no maximum actor restart limit by @isra17 in #153
• ray: Handle disconnection to ray cluster by @isra17 in #155
• ray: replace dead actors by @isra17 in #156

Full Changelog: v0.2.0dev46...v0.2.0dev49