delta/openstack/taskflow.git/taskflow/utils/iter_utils.py, 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

Drop use of deprecated collections classes

2020-04-14T18:31:44+00:00

Many classes have moved from collections to collections.abc. The
original imports work, but emit deprecation warnings.

Now that we are py3-only, we can drop any references to the older
deprecated locations.

Change-Id: I24b13c8654a33d99bf687a44a36cfdace39e3866
Signed-off-by: Sean McGinnis

Remove vim header from source files

2016-11-09T08:06:10+00:00

Trivial fix

[H106] Don't put vim configuration in source files (off by default).

Change-Id: I7e9e9930fd6f135074078637f5af6f403e75ff78

Fix wrong usage of iter_utils.unique_seen

2016-01-10T06:42:17+00:00

This wasn't actually using the right data to derive
uniqueness, so fix it to actually use the right entry
to determine what to skip or what not to skip.

Closes-Bug: #1525379

Change-Id: Ic23b6d03877f7714f6a3fb74adac0ba58cd97f0d

Add ability of job poster/job iterator to wait for jobs to complete

2015-12-16T16:19:24+00:00

It is quite useful for someone who has posted a job to be able to
easily wait for its completion (up to a given timeout) so add a wait
method onto the job class to allow for this to be possible.

Change-Id: Id3a7c724020962591e323da0febfd0c71d1acc50

Move 'fill_iter' to 'iter_utils.fill'

2015-10-27T00:54:30+00:00

This is better placed in the iterator utility module
as it acts on iterables and provides its own iterator
that fills up to (and potentially beyond) a provided
iterator.

Also adds some nice tests to make sure it keeps on
working as expected; as well as tests for other parts
of iter_utils to ensure they keep on working as
expected as well.

Change-Id: Ica90816cbdedfd87f3861a111d7a852655c1fb74

feat: add max_dispatches arg to conductor's run

2015-10-15T20:05:33+00:00

- This will cause the conductor to only do 'n' number of dispatches,
  after which it stops dispatching jobs.

- This will allow the code that call the conductor, to monitor
  conductor.dispatching, and make a decision on what is to be done with
  it. Eg: Decomission a conductor, restart the conductor etc

- Backward Compatible.

Change-Id: I3386c7050806806b5ee44a74ba93e50515a5ab7b

Simplify flow action engine compilation

2015-10-02T05:38:30+00:00

Instead of the added complexity of discarding flow nodes
we can simplify the compilation process by just retaining
them and jumping over them in further iteration and graph
and tree runtime usage.

This change moves toward a model that does just this, which
makes it also easier to in the future use the newly added
flow graph nodes to do meaningful things (like use them as
a point to change which flow_detail is used).

Change-Id: Icb1695f4b995a0392f940837514774768f222db4

Replace the tree 'pformat()' recursion with non-recursive variant

2015-07-27T18:20:39+00:00

This adjusted variant creates the same output but is hopefully
easier to understand and follow than the recursive version.

This version is also not limited by the python stack limit which
is a general good thing to avoid being limited by.

It also adds a bunch of tests to make sure the format is as expected
under various tree structures.

Change-Id: I2ae42c7c1bf72794800929250bcf6ccbe658230b