<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/openstack/taskflow.git/taskflow/conductors, branch 0.7.1</title>
<subtitle>opendev.org: openstack/taskflow.git
</subtitle>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/'/>
<entry>
<title>Merge "catch NotFound errors when consuming or abandoning"</title>
<updated>2015-02-15T05:25:13+00:00</updated>
<author>
<name>Jenkins</name>
<email>jenkins@review.openstack.org</email>
</author>
<published>2015-02-15T05:25:13+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=5ee7e94e5ecbbfae90e969f040e4c5b6d31d3dfa'/>
<id>5ee7e94e5ecbbfae90e969f040e4c5b6d31d3dfa</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Mark conductor 'stop' method deprecation kwarg with versions</title>
<updated>2015-02-13T04:50:42+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-02-13T01:26:41+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=0bcd1eb863854a64540ce21fe081af9e16167266'/>
<id>0bcd1eb863854a64540ce21fe081af9e16167266</id>
<content type='text'>
To make it known (when the warning message is emitted) what
version this was deprecated in and when it may be removed
in add those parameters to the 'removed_kwarg' decorator so that
users of conductors are aware of this information.

Change-Id: Iacc97831ccd96d68cea4bd7e65a967b5ff9e7dc5
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
To make it known (when the warning message is emitted) what
version this was deprecated in and when it may be removed
in add those parameters to the 'removed_kwarg' decorator so that
users of conductors are aware of this information.

Change-Id: Iacc97831ccd96d68cea4bd7e65a967b5ff9e7dc5
</pre>
</div>
</content>
</entry>
<entry>
<title>catch NotFound errors when consuming or abandoning</title>
<updated>2015-02-12T21:07:02+00:00</updated>
<author>
<name>Dan Krause</name>
<email>dan.krause@rackspace.com</email>
</author>
<published>2015-02-12T21:07:02+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=073eb325b6870edf100e3780540e921cc5e56496'/>
<id>073eb325b6870edf100e3780540e921cc5e56496</id>
<content type='text'>
If the zk node disappears underneath the conductor before it attempts to
abandon or consume a job, consumption/abandonment would fail with an
uncaught exception, killing the conductor. Catching excp.NotFound corrects
this.

Change-Id: Iaa7d0d8d0ebbc76973f16d717cc3137c75fbfec2
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
If the zk node disappears underneath the conductor before it attempts to
abandon or consume a job, consumption/abandonment would fail with an
uncaught exception, killing the conductor. Catching excp.NotFound corrects
this.

Change-Id: Iaa7d0d8d0ebbc76973f16d717cc3137c75fbfec2
</pre>
</div>
</content>
</entry>
<entry>
<title>Modify stop and add wait on conductor to prevent lockups</title>
<updated>2015-02-09T23:30:27+00:00</updated>
<author>
<name>Min Pae</name>
<email>sputnik13@gmail.com</email>
</author>
<published>2015-02-09T22:50:41+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=e7df6c66f041218b204a8b0785da0ee1b728dbda'/>
<id>e7df6c66f041218b204a8b0785da0ee1b728dbda</id>
<content type='text'>
Removed _dead.wait from the stop method and added a wait method to
explicitly wait for graceful shutdown.  Implicitly waiting for
graceful shutdown in the stop method is leading to potential
deadlock situations when conductor is running in the main thread
and a signal handler is used to kick off stop/shutdown.

Also in larger systems, it is desirable to be able to initiate
shutdown on all running services then wait/join everything together
so as not to force a serial shutdown pattern.

Change-Id: Ic74dab22b09100c5b653d12c2518f83a1bf8e859
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Removed _dead.wait from the stop method and added a wait method to
explicitly wait for graceful shutdown.  Implicitly waiting for
graceful shutdown in the stop method is leading to potential
deadlock situations when conductor is running in the main thread
and a signal handler is used to kick off stop/shutdown.

Also in larger systems, it is desirable to be able to initiate
shutdown on all running services then wait/join everything together
so as not to force a serial shutdown pattern.

Change-Id: Ic74dab22b09100c5b653d12c2518f83a1bf8e859
</pre>
</div>
</content>
</entry>
<entry>
<title>Add and use a new simple helper logging module</title>
<updated>2014-12-09T06:09:13+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@gmail.com</email>
</author>
<published>2014-09-21T17:37:35+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=14431bc0769673fe5a70182189e2d4038a804cd8'/>
<id>14431bc0769673fe5a70182189e2d4038a804cd8</id>
<content type='text'>
Add a new logging BLATHER level to easily allow its
usage for messages that are below the normal DEBUG level
such as compilation information and scope lookup info
which can be very verbose in logs if always enabled.

Change-Id: I828211403bd02bfd6777b10cdcfe58fb0637a52c
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Add a new logging BLATHER level to easily allow its
usage for messages that are below the normal DEBUG level
such as compilation information and scope lookup info
which can be very verbose in logs if always enabled.

Change-Id: I828211403bd02bfd6777b10cdcfe58fb0637a52c
</pre>
</div>
</content>
</entry>
<entry>
<title>Merge "Use and verify event and latch wait() return using timeouts"</title>
<updated>2014-10-19T02:53:47+00:00</updated>
<author>
<name>Jenkins</name>
<email>jenkins@review.openstack.org</email>
</author>
<published>2014-10-19T02:53:47+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=c95a681a9fdee40eefb098b52e98548092a6dbe4'/>
<id>c95a681a9fdee40eefb098b52e98548092a6dbe4</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Use and verify event and latch wait() return using timeouts</title>
<updated>2014-10-19T00:51:52+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2014-09-02T19:36:52+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=7ca631356efd943bf8e246a6a907653a70a35771'/>
<id>7ca631356efd943bf8e246a6a907653a70a35771</id>
<content type='text'>
Instead of blocking up the whole test suite when a latch or
event was not decremented to its desired value (or not set for
an event) we should use a reasonably high value that we use
when waiting for those actions to occur and verify that when those
wait() functions return that we have reached the desired state and
if not either raise an exception or stop further testing.

Fixes bug 1363739

Change-Id: I8b40282ac2db9cabd48b0b65c8a2a49610d77c4f
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Instead of blocking up the whole test suite when a latch or
event was not decremented to its desired value (or not set for
an event) we should use a reasonably high value that we use
when waiting for those actions to occur and verify that when those
wait() functions return that we have reached the desired state and
if not either raise an exception or stop further testing.

Fixes bug 1363739

Change-Id: I8b40282ac2db9cabd48b0b65c8a2a49610d77c4f
</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://git.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>Have the dispatch_job function return a future</title>
<updated>2014-08-21T22:14:35+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2014-07-01T03:26:26+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=296e660cd3036db46a58ed3b16c907c769454f05'/>
<id>296e660cd3036db46a58ed3b16c907c769454f05</id>
<content type='text'>
To make it easier to add in a multi-threaded conductor
convert the base dispatch_job function to return a future
object. This future object will contain a single result,
whether the job should be consumed or abandoned. In the
single threaded conductor its dispatch_job function will
return a future, after completing the job (in a multi
threaded conductor it would not return a future after
doing the work).

Change-Id: I077334820d36c64e272e93d158e3a0cd0d66a937
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
To make it easier to add in a multi-threaded conductor
convert the base dispatch_job function to return a future
object. This future object will contain a single result,
whether the job should be consumed or abandoned. In the
single threaded conductor its dispatch_job function will
return a future, after completing the job (in a multi
threaded conductor it would not return a future after
doing the work).

Change-Id: I077334820d36c64e272e93d158e3a0cd0d66a937
</pre>
</div>
</content>
</entry>
<entry>
<title>Merge "Add a pformat() failure method and use it in the conductor"</title>
<updated>2014-08-21T21:31:55+00:00</updated>
<author>
<name>Jenkins</name>
<email>jenkins@review.openstack.org</email>
</author>
<published>2014-08-21T21:31:55+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=73125ee0fd4fa42002e06285b193365c3f70c776'/>
<id>73125ee0fd4fa42002e06285b193365c3f70c776</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
