<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/openstack/taskflow.git/taskflow/utils/misc.py, branch 2.5.0</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>Instead of a multiprocessing queue use sockets via asyncore</title>
<updated>2016-05-24T23:16:56+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-11-12T00:33:49+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=c5e9cf28df9dda763d146859b1472d8bbcf85665'/>
<id>c5e9cf28df9dda763d146859b1472d8bbcf85665</id>
<content type='text'>
For a local process based executor usage currently to ensure
that task emitted notifications are proxied we use the multi
processing library and use its queue concept. This sadly creates
a proxy process that gets associated, and this proxy process
handles the queue and messages sent to and from it. Instead of
doing this we can instead just create a temporary local socket
using a random socket and have tasks (which are running in
different processes) use that to communicate back any emitted
notifications instead (and we can use the asyncore module to handle
the emitted notifications since it handles the lower level socket
reading, polling and dispatching).

To ensure that the socket created is somewhat secure we use a
similar process as the multi-processing library uses where we
sign all messages with a hmac that uses a one time key that only
the main process and the child process know about (and reject
any messages that do not validate using this key).

Change-Id: Iff9180054bf14495e5667af00ae2fafbdbc23791
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
For a local process based executor usage currently to ensure
that task emitted notifications are proxied we use the multi
processing library and use its queue concept. This sadly creates
a proxy process that gets associated, and this proxy process
handles the queue and messages sent to and from it. Instead of
doing this we can instead just create a temporary local socket
using a random socket and have tasks (which are running in
different processes) use that to communicate back any emitted
notifications instead (and we can use the asyncore module to handle
the emitted notifications since it handles the lower level socket
reading, polling and dispatching).

To ensure that the socket created is somewhat secure we use a
similar process as the multi-processing library uses where we
sign all messages with a hmac that uses a one time key that only
the main process and the child process know about (and reject
any messages that do not validate using this key).

Change-Id: Iff9180054bf14495e5667af00ae2fafbdbc23791
</pre>
</div>
</content>
</entry>
<entry>
<title>Remove deprecated things for 2.0 release</title>
<updated>2016-05-10T22:26:57+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-07-06T22:31:29+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=afbfe77a7f7bad87c3e95b4f0c94cab84258a5bb'/>
<id>afbfe77a7f7bad87c3e95b4f0c94cab84258a5bb</id>
<content type='text'>
Change-Id: Id9adbc50bd51adc77ce88f698ad0ea2ee63fc5e2
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Change-Id: Id9adbc50bd51adc77ce88f698ad0ea2ee63fc5e2
</pre>
</div>
</content>
</entry>
<entry>
<title>Allow cachedproperty to avoid locking</title>
<updated>2016-02-09T07:16:58+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@gmail.com</email>
</author>
<published>2016-02-09T07:16:58+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=b033fa672227720ae64bca25eafffc87d5fea42a'/>
<id>b033fa672227720ae64bca25eafffc87d5fea42a</id>
<content type='text'>
Under some cirumstances it is ok to recompute
a value when raced to by multiple threads, for these
cases allow the cachedproperty to avoid needing and
using a lock.

Change-Id: Icb71cb5ea280185cfb120671be900435dabcd50b
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Under some cirumstances it is ok to recompute
a value when raced to by multiple threads, for these
cases allow the cachedproperty to avoid needing and
using a lock.

Change-Id: Icb71cb5ea280185cfb120671be900435dabcd50b
</pre>
</div>
</content>
</entry>
<entry>
<title>Allow for alterations in decider 'area of influence'</title>
<updated>2016-01-10T06:42:17+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-11-17T00:27:42+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=8e8156c488dea8ae876b112c30e41e60da4f5be7'/>
<id>8e8156c488dea8ae876b112c30e41e60da4f5be7</id>
<content type='text'>
Christmas came early.

Closes-Bug: #1479466

Change-Id: I931d826690c925f022dbfffe9afb7bf41345b1d0
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Christmas came early.

Closes-Bug: #1479466

Change-Id: I931d826690c925f022dbfffe9afb7bf41345b1d0
</pre>
</div>
</content>
</entry>
<entry>
<title>Merge "Use the retrying lib. to do basic sqlalchemy engine validation"</title>
<updated>2016-01-09T01:27:54+00:00</updated>
<author>
<name>Jenkins</name>
<email>jenkins@review.openstack.org</email>
</author>
<published>2016-01-09T01:27:54+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=8bd70574db1233dcc612ec2c899b998060bb4a26'/>
<id>8bd70574db1233dcc612ec2c899b998060bb4a26</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Use the retrying lib. to do basic sqlalchemy engine validation</title>
<updated>2016-01-06T06:34:43+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-12-22T23:13:19+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=25dca8eb593caf821b29a27f120bdcbd0e223024'/>
<id>25dca8eb593caf821b29a27f120bdcbd0e223024</id>
<content type='text'>
Instead of a custom loop and backoff just use the retrying
library to do this same code and delegate the loop complexity
to it instead.

Change-Id: Iaf02cc728d2a2cfc7077300e03d7ef25522717b7
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Instead of a custom loop and backoff just use the retrying
library to do this same code and delegate the loop complexity
to it instead.

Change-Id: Iaf02cc728d2a2cfc7077300e03d7ef25522717b7
</pre>
</div>
</content>
</entry>
<entry>
<title>Use shared util helper for driver name + config extraction</title>
<updated>2015-12-23T01:15:32+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-12-23T01:15:32+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=c145bef2247ebb5ac56c6429b301ae1de622bc37'/>
<id>c145bef2247ebb5ac56c6429b301ae1de622bc37</id>
<content type='text'>
Change-Id: I43465b8f5868e64bdf38d2873417a8a4a403a23b
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Change-Id: I43465b8f5868e64bdf38d2873417a8a4a403a23b
</pre>
</div>
</content>
</entry>
<entry>
<title>Merge "Change name of misc.ensure_dict to misc.safe_copy_dict"</title>
<updated>2015-12-15T05:38:04+00:00</updated>
<author>
<name>Jenkins</name>
<email>jenkins@review.openstack.org</email>
</author>
<published>2015-12-15T05:38:04+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=f115d9a6a15edc946e0a1803869a22d451b87d3f'/>
<id>f115d9a6a15edc946e0a1803869a22d451b87d3f</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Change name of misc.ensure_dict to misc.safe_copy_dict</title>
<updated>2015-12-15T00:18:11+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-12-15T00:16:04+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=69eb1e1b73bdb5bec437d10acb923564bc5610a6'/>
<id>69eb1e1b73bdb5bec437d10acb923564bc5610a6</id>
<content type='text'>
Change-Id: I2ff3b9bb4d0b8143163e4bf370f10c74e79dbd31
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Change-Id: I2ff3b9bb4d0b8143163e4bf370f10c74e79dbd31
</pre>
</div>
</content>
</entry>
<entry>
<title>Move validation of compiled unit out of compiler</title>
<updated>2015-11-20T21:16:42+00:00</updated>
<author>
<name>Joshua Harlow</name>
<email>harlowja@yahoo-inc.com</email>
</author>
<published>2015-10-07T18:56:26+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/openstack/taskflow.git/commit/?id=0b034d611f56d8d6d855cf147caeb3d0f8d6068f'/>
<id>0b034d611f56d8d6d855cf147caeb3d0f8d6068f</id>
<content type='text'>
Instead of having the compiler do any validation on the
graph it has created instead have the compiler just compile
and have the engine that uses that compiled result do any
post compilation validation instead.

This makes it more clear that the compiler just compiles a
flow (and tasks and nested flows) into a graph, and that is
all that it does.

Change-Id: I96a35d732dc2be9fc8bc8dc6466256a19ac2df6d
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Instead of having the compiler do any validation on the
graph it has created instead have the compiler just compile
and have the engine that uses that compiled result do any
post compilation validation instead.

This makes it more clear that the compiler just compiles a
flow (and tasks and nested flows) into a graph, and that is
all that it does.

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