Add outbox(fanout exchange) support for actors
Add basic workflow entities and examples (prototype version)
Add 3 exchanges per actor type(direct, round_robin and scatter)
Add workflow module
Add result property to AsyncResult
(it blocks if the result has not been previously retrieved, or return the
result otherwise)
Add prototype actors for RPC (this is an experiment)
Add example of how custom operators can be created on top of actors
Remove local actors support (the _inbox property of type Mailbox)
Remove unused imports (left from the local actors implementation)
Use the Server class (an Actor derived class)
Cleaning: Remove prints
Cleaning: Fix typo in comments
remove DuplicateOutputError class
Fix broken comment
Remove actors' exchanges excplicit binding
1)Add remove_binding support; 2)Create actors exchanges with
auto_delete=False
Add comment with an example usage of remote actors
flakes
workflow: fixes + cosmetics
Moves distributed agent from celery to agents.dAgent