delta/openstack/taskflow.git/taskflow/engines/worker_based/proxy.py, branch 2.5.0

Remove 2.6 classifier + 2.6 compatibility code

2015-06-21T16:39:12+00:00

Fixes bug 1445827

Depends-On: I02e3c9aacef0b295a2f823a5cbaf11768a90cb82

Change-Id: I1db681803598ac1bc917fd74a99458bc61edf3f1

Abstract out the worker finding from the WBE engine

2015-02-01T07:03:25+00:00

To be able to easily plug-in future types of ways to get
which topics (and tasks) workers exist on (and can perform)
and to identify and keep this information up-to date refactor
the functionality that currently does this using periodic messages
into a finder type and a periodic function that exists on
it (that will be periodically activated by an updated and
improved periodic worker).

Part of blueprint wbe-worker-info

Change-Id: Ib3ae29758af3d244b4ac4624ac380caf88b159fd

Add and use a nicer kombu message formatter

2015-01-30T06:59:54+00:00

Since the kombu message object that is recieved has
no useful __str__ or __repr__ and on reception and processing
we should the message (and the delivery tag) it is nice to have
a more useful formatting of that message for debugging and
such (where more detail about the messages are quite useful
to see).

Change-Id: I6730b10122a5de1a0a074525931f312fbd97b8c0

Use kombu socket.timeout alias instead of socket.timeout

2015-01-29T09:00:58+00:00

Use the kombu timeout error alias to socket.timeout to
be more resilient against kombu ever changing this exception
type to something different.

Change-Id: I53c01db67742c65ee49264fd0d8d36417cec3ec1

Merge "Link WBE docs together better (especially around arguments)"

2015-01-29T08:37:12+00:00

Merge "Emit a warning when no routing keys provided on publish()"

2015-01-29T07:36:11+00:00

Add docstring to wbe proxy to denote not for public use

2015-01-28T16:50:28+00:00

Change-Id: I9bd59ae5d58ef3ace960509903403252fbed6277

Link WBE docs together better (especially around arguments)

2015-01-27T00:34:30+00:00

Link the engine/worker 'retry_options' to the proxy which has
linkage to what the defaults are and to where more information
can be gathered about the option (which really gets sent in to
kombu) so that users can more easily understand it.

Also removes showing the docs about the following as its
more of an internal API/class not meant for public consumption:

* Module: taskflow.engines.worker_based.executor

Change-Id: Ib16ee10765ec6b9a0af320bd6818d9649c2485b1

Emit a warning when no routing keys provided on publish()

2015-01-26T16:51:38+00:00

When no routing keys are provided the message will no be
published anywhere; so when this happens emit a warning to
tell the library user that something is likely misconfigured
and/or wrong.

Change-Id: Id27e8ab73c1ae8a02cb4252958d9dc896a5df1f0

Use explicit WBE object arguments (instead of kwargs)

2015-01-22T20:13:17+00:00

Instead of passing around kwargs to root WBE classes and to
contained classes prefer to use explicitnamed arguments that are
passed around. This makes the code more obvious as to what
the intended arguments are and makes it easier for error validation
when other unknown arguments are passed (as well as for docs).

Also moves the docs for the worker engine to be a sub-TOC under
the main engine document so that it can be more easily explored
and managed/found...

Change-Id: I9413fad187c330fee494f0d4536cc27d9a90f0fb