<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/openstack/taskflow.git/taskflow/engines/worker_based/engine.py, branch master</title>
<subtitle>opendev.org: openstack/taskflow.git
</subtitle>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/'/>
<entry>
<title>set default python to python3</title>
<updated>2018-04-17T20:29:54+00:00</updated>
<author>
<name>Doug Hellmann</name>
<email>doug@doughellmann.com</email>
</author>
<published>2018-04-13T20:16:14+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=f4948aec9d11064570b2a4e43adac49888e8f122'/>
<id>f4948aec9d11064570b2a4e43adac49888e8f122</id>
<content type='text'>
Set the default python to python3 except for the py27 environment. We
have to set that explicitly to override the new default.

Have py27 and py3* jobs run same commands by removing the commands entry
for py27.

The pep8 rules under python 3 are different, so we need to fix a
couple of issues with blank space. The E721 rule is ignored entirely
because we are not yet using a version of flake8 that supports
ignoring individual rules on specific lines, although the instructions
for that are added so that when we upgrade flake8 to a newer version
we can remove the global rule.

Change-Id: Id236b0632a83a188958130d04f1e9c476c5ace65
Signed-off-by: Doug Hellmann &lt;doug@doughellmann.com&gt;
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Set the default python to python3 except for the py27 environment. We
have to set that explicitly to override the new default.

Have py27 and py3* jobs run same commands by removing the commands entry
for py27.

The pep8 rules under python 3 are different, so we need to fix a
couple of issues with blank space. The E721 rule is ignored entirely
because we are not yet using a version of flake8 that supports
ignoring individual rules on specific lines, although the instructions
for that are added so that when we upgrade flake8 to a newer version
we can remove the global rule.

Change-Id: Id236b0632a83a188958130d04f1e9c476c5ace65
Signed-off-by: Doug Hellmann &lt;doug@doughellmann.com&gt;
</pre>
</div>
</content>
</entry>
<entry>
<title>Add WBE worker expiry</title>
<updated>2016-02-14T20:37:01+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@gmail.com</email>
</author>
<published>2016-02-06T18:19:05+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=63b380fc7b4a633911ec65e87ca326cf677986ce'/>
<id>63b380fc7b4a633911ec65e87ca326cf677986ce</id>
<content type='text'>
When a worker hasn't responded to a notification
request for a given amount of time remove it from
being a useable worker that we can match task submissions
to.

Change-Id: I596bccc1c42f83ee79136dd27bc87039154ff7b1
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
When a worker hasn't responded to a notification
request for a given amount of time remove it from
being a useable worker that we can match task submissions
to.

Change-Id: I596bccc1c42f83ee79136dd27bc87039154ff7b1
</pre>
</div>
</content>
</entry>
<entry>
<title>Make the dispatcher handler be an actual type</title>
<updated>2015-02-16T04:21:24+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@gmail.com</email>
</author>
<published>2015-02-16T04:03:53+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=d1b6776435644330698722143e36c37b9c3ca375'/>
<id>d1b6776435644330698722143e36c37b9c3ca375</id>
<content type='text'>
Instead of having the dispatcher target be a tuple
or a single callback, have it be an actual type with
comments as to what the types fields are and how they
are used.

This makes it more obvious as to what those fields are
and how they are used so that it is easier to understand
how the WBE engine and components work.

Change-Id: I5541ccd5a7aa6ae73ed9adceeac2c0524e2a1dc9
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Instead of having the dispatcher target be a tuple
or a single callback, have it be an actual type with
comments as to what the types fields are and how they
are used.

This makes it more obvious as to what those fields are
and how they are used so that it is easier to understand
how the WBE engine and components work.

Change-Id: I5541ccd5a7aa6ae73ed9adceeac2c0524e2a1dc9
</pre>
</div>
</content>
</entry>
<entry>
<title>Default to using a thread-safe storage unit</title>
<updated>2015-02-06T07:19:08+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-02-06T00:31:33+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=08a184639635c57735c5ce0ca60aa727777c9e69'/>
<id>08a184639635c57735c5ce0ca60aa727777c9e69</id>
<content type='text'>
Instead of having a nominally useful single-threaded storage
unit that uses a dummy r/w lock and a multi-threaded storage
unit just have the storage unit by default protect itself from
multi-threading calls being used on it (with the appropriate
reader/writer locks being activated to make this work
correctly).

Change-Id: Ib6879edb465156a8e54fd5b4002550d1cec49137
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Instead of having a nominally useful single-threaded storage
unit that uses a dummy r/w lock and a multi-threaded storage
unit just have the storage unit by default protect itself from
multi-threading calls being used on it (with the appropriate
reader/writer locks being activated to make this work
correctly).

Change-Id: Ib6879edb465156a8e54fd5b4002550d1cec49137
</pre>
</div>
</content>
</entry>
<entry>
<title>Link WBE docs together better (especially around arguments)</title>
<updated>2015-01-27T00:34:30+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-01-27T00:26:56+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=7fe2945813450cd0ba1264171c5a90dc0f90d57f'/>
<id>7fe2945813450cd0ba1264171c5a90dc0f90d57f</id>
<content type='text'>
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
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
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
</pre>
</div>
</content>
</entry>
<entry>
<title>Increase robustness of WBE producer/consumers</title>
<updated>2015-01-20T23:07:56+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-01-16T23:37:44+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=cb27080ea3cd5cddd7f91d866f6a9d1214c9e885'/>
<id>cb27080ea3cd5cddd7f91d866f6a9d1214c9e885</id>
<content type='text'>
Use the kombu provided ensure() decorator/wrapper along
with sensible default settings to ensure that retries are
attempted when kombu detects recoverable connection or
recoverable channel errors have occurred.

Change-Id: If47f72d02561d0b5d556ac386869a6122c8b871d
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Use the kombu provided ensure() decorator/wrapper along
with sensible default settings to ensure that retries are
attempted when kombu detects recoverable connection or
recoverable channel errors have occurred.

Change-Id: If47f72d02561d0b5d556ac386869a6122c8b871d
</pre>
</div>
</content>
</entry>
<entry>
<title>Allow specifying the engine 'executor' as a string</title>
<updated>2015-01-02T04:16:43+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2014-12-23T23:33:13+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=b52db18522a938a995039790649821b65c26ef67'/>
<id>b52db18522a938a995039790649821b65c26ef67</id>
<content type='text'>
To enable a parallel process executor to be used without
having to pass in a futures executor allow for the executor
option to be a string 'processes' (or similar) that will cause
the default parallel process executor to be used automatically.

Also allow for a 'threads' string that ensure a parallel thread
executor is used to match the ability to uses processes.

This also adjusts the WBE engine to have a similar executor fetching
function (which in the WBE case now validates a provided executor to
be of the desired type).

Change-Id: I54a82584c32c697922507b4f6e01ea7b8acc73c6
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
To enable a parallel process executor to be used without
having to pass in a futures executor allow for the executor
option to be a string 'processes' (or similar) that will cause
the default parallel process executor to be used automatically.

Also allow for a 'threads' string that ensure a parallel thread
executor is used to match the ability to uses processes.

This also adjusts the WBE engine to have a similar executor fetching
function (which in the WBE case now validates a provided executor to
be of the desired type).

Change-Id: I54a82584c32c697922507b4f6e01ea7b8acc73c6
</pre>
</div>
</content>
</entry>
<entry>
<title>Get the basics of a process executor working</title>
<updated>2014-12-20T04:48:23+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2014-09-13T01:49:29+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=2a8fde1798dbcaab53d0a1aba9740f729ba64f83'/>
<id>2a8fde1798dbcaab53d0a1aba9740f729ba64f83</id>
<content type='text'>
Since we support various executors (threaded and distributed)
the next best executor when a threaded executor will not perform
and a distributed one requires to much setup is a local process
based one so it would be great to support this where we can.

Things that are currently (likely never) not going to work:

 * Non-pickleable/non-copyable tasks
 * Tasks that return non-pickleable/non-copyable results
 * Tasks that use non-pickleable/non-copyable args/kwargs

Part of blueprint process-executor

Change-Id: I966ae01d390c7217b858db3feb2db949ce5c08d1
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Since we support various executors (threaded and distributed)
the next best executor when a threaded executor will not perform
and a distributed one requires to much setup is a local process
based one so it would be great to support this where we can.

Things that are currently (likely never) not going to work:

 * Non-pickleable/non-copyable tasks
 * Tasks that return non-pickleable/non-copyable results
 * Tasks that use non-pickleable/non-copyable args/kwargs

Part of blueprint process-executor

Change-Id: I966ae01d390c7217b858db3feb2db949ce5c08d1
</pre>
</div>
</content>
</entry>
<entry>
<title>Deprecate `engine_conf` and prefer `engine` instead</title>
<updated>2014-10-18T20:28:27+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@gmail.com</email>
</author>
<published>2014-09-17T05:46:39+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=d433a5323ff4fbf1d973ca7605ac62819c19039a'/>
<id>d433a5323ff4fbf1d973ca7605ac62819c19039a</id>
<content type='text'>
To avoid having one set of options coming from `engine_conf`
and another set of options coming from `kwargs` and another set
coming from `engine_conf` if it is a URI just start to shift
toward `engine_conf` being deprecated and `engine` being a string
type only (or a URI with additional query parameters) and having
any additional **kwargs that are provided just get merged into the
final engine options.

This adds a new helper function that handles all these various
options and adds in a keyword argument `engine` that will be shifted
to in a future version (in that future version we can also then
remove the `engine_conf` and just stick to a smaller set of option
mechanisms).

It also adjusts all examples to use this new and more easier to
understand format and adjusts tests, conductor interface to use
this new more easily understandable style of getting an engine.

Change-Id: Ic7617057338e0c63775cf38a24643cff6e454950
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
To avoid having one set of options coming from `engine_conf`
and another set of options coming from `kwargs` and another set
coming from `engine_conf` if it is a URI just start to shift
toward `engine_conf` being deprecated and `engine` being a string
type only (or a URI with additional query parameters) and having
any additional **kwargs that are provided just get merged into the
final engine options.

This adds a new helper function that handles all these various
options and adds in a keyword argument `engine` that will be shifted
to in a future version (in that future version we can also then
remove the `engine_conf` and just stick to a smaller set of option
mechanisms).

It also adjusts all examples to use this new and more easier to
understand format and adjusts tests, conductor interface to use
this new more easily understandable style of getting an engine.

Change-Id: Ic7617057338e0c63775cf38a24643cff6e454950
</pre>
</div>
</content>
</entry>
<entry>
<title>Allow WBE request transition timeout to be dynamic</title>
<updated>2014-08-12T19:30:11+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@gmail.com</email>
</author>
<published>2014-08-12T19:12:56+00:00</published>
<link rel='alternate' type='text/html' href='http://trove.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=c491683650f0912b6bc613a5a819aaf4f32c4340'/>
<id>c491683650f0912b6bc613a5a819aaf4f32c4340</id>
<content type='text'>
To enable longer (or shorter) timeouts for a WBE submitted
request to transition out of the (PENDING, WAITING) states
allow the transition timeout that was previously set to 60
seconds to be provided as a WBE configuration option (it
still defaults to the previously fixed 60 seconds when it
is not provided).

Fixes bug 1356002

Change-Id: Idf384217004a334df03e2fff9150309fdfe08005
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
To enable longer (or shorter) timeouts for a WBE submitted
request to transition out of the (PENDING, WAITING) states
allow the transition timeout that was previously set to 60
seconds to be provided as a WBE configuration option (it
still defaults to the previously fixed 60 seconds when it
is not provided).

Fixes bug 1356002

Change-Id: Idf384217004a334df03e2fff9150309fdfe08005
</pre>
</div>
</content>
</entry>
</feed>
