delta/openstack/taskflow.git/taskflow/tests/unit/worker_based, branch master

Remove six

2022-05-18T07:12:37+00:00

This library no longer supports Python 2, thus usage of six can be
removed. This also removes workaround about pickle library used in
Python 2 only.

Change-Id: I19d298cf0f402d65f0b142dea0bf35cf992332a9

Use LOG.warning instead of deprecated LOG.warn

2021-11-29T05:30:04+00:00

The LOG.warn method is deprecated[1] and the LOG.warning method should
be used instead.

[1] https://docs.python.org/3/library/logging.html#logging.warning

Change-Id: I4321a489c56eb1aa650e776ee35d8f88d4d8910c

Use unittest.mock instead of mock

2021-04-27T21:47:11+00:00

The mock third party library was needed for mock support in py2
runtimes. Since we now only support py36 and later, we can use the
standard lib unittest.mock module instead.

Change-Id: Ib169e3deb7ddb2bc93a206ebec4043552281aa7f

Fix invalid json unit test

2018-02-08T17:13:05+00:00

Recent versions of oslo.serialization have made it possible to dump
exceptions to JSON, which broke a unit test in taskflow that
assumed exceptions were unserializable.  This change switches to an
explicitly unserializable class for that test.

Change-Id: If6d19bc9fcf1f1813cb087d42dc7ba6a61c71b3d
Closes-Bug: 1748241

Replace assertEqual(None, *) with assertIsNone in tests

2016-07-12T03:46:19+00:00

Replace assertEqual(None, *) with assertIsNone in tests to have more
clear messages in case of failure.

Change-Id: I74452af6d840bcf612fd3bb2521db9134460dd63
Closes-Bug: #1280522

Make tests less dependent on transient state

2016-06-02T17:46:55+00:00

Having to update the endpoint count every time  you add a test
class is really obnoxious and leads to a ton of pointless rebasing.
Now we just check that it finds at least the task it knows about
and call that good.

Change-Id: I96b8c6cd6cbc1fdc58dee4b18cab5699e3daa844

Instead of a multiprocessing queue use sockets via asyncore

2016-05-24T23:16:56+00:00

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

Make conductor.stop stop the running engine gracefully

2016-05-03T17:59:18+00:00

Previously stopping the conductor would only prevent it from
accepting new jobs.  This change makes it abort the current job
by telling the engine to stop processing tasks after the current
ones finish.

This allows for conductors to gracefully exit when receiving a kill
signal (although the signal handling is not done automatically yet).

Change-Id: Ie6ddcbb2df4508ad1e3f6698c6f4cb2fc26a278f

Merge "Use a automaton machine for WBE request state machine"

2016-04-28T20:29:37+00:00

Allow for revert to have a different argument list from execute

2016-02-26T19:45:33+00:00

Also allows for people to create Atom's with a different rebind
or requires structure for the revert method, if desired.

Implements blueprint: seperate-revert-args

Change-Id: Ie7d13c8000ef08ff303481d486d1ba1cfbdeea44