Sriram Madapusi Vasudevan 5f5fdd1811 feat: add max_dispatches arg to conductor's run ...

- This will cause the conductor to only do 'n' number of dispatches,
  after which it stops dispatching jobs.

- This will allow the code that call the conductor, to monitor
  conductor.dispatching, and make a decision on what is to be done with
  it. Eg: Decomission a conductor, restart the conductor etc

- Backward Compatible.

Change-Id: I3386c7050806806b5ee44a74ba93e50515a5ab7b

2015-10-15 16:05:33 -04:00

..

__init__.py

Removed copyright from empty files

2014-02-22 17:16:29 +08:00

async_utils.py

Bump futurist and remove waiting code in taskflow

2015-07-25 18:54:22 -07:00

deprecation.py

Move to the newer debtcollector provided functions

2015-03-20 21:00:11 -07:00

eventlet_utils.py

Use importutils.try_import for optional eventlet imports

2015-01-25 11:10:14 -08:00

iter_utils.py

feat: add max_dispatches arg to conductor's run

2015-10-15 16:05:33 -04:00

kazoo_utils.py

Merge "Remove kazoo hack/fix for issue no longer needed"

2015-07-21 04:39:20 +00:00

kombu_utils.py

Add todo note for kombu pull request

2015-02-16 21:55:44 -08:00

misc.py

Extend and improve failure logging

2015-08-07 00:09:11 -07:00

mixins.py

Use encodeutils for exception -> string function

2015-06-30 17:08:45 -07:00

persistence_utils.py

Remove **most** usage of taskflow.utils in examples

2015-07-17 08:48:17 -07:00

redis_utils.py

Build-out + test a redis backed jobboard

2015-06-29 12:13:01 -07:00

schema_utils.py

Add + use failure json schema validation

2015-03-11 12:53:15 -07:00

threading_utils.py

Integrate futurist (and **remove** taskflow originating code)

2015-07-09 15:01:35 -07:00