CHANGES¶
[stable-only] Cap virtualenv for py37
Update TOX/UPPER_CONSTRAINTS_FILE for stable/ussuri
Update .gitreview for stable/ussuri
4.1.0¶
Zookeeper backend SSL support
4.0.0¶
[ussuri][goal] Drop python 2.7 support and testing
3.8.0¶
Switch to Ussuri jobs
Update TaskFlow for networkx 2.x
Update master for stable/train
Fix python3.8 hmac compatibility
3.7.1¶
Use mysql LONGTEXT for atomdetails results
Add Python 3 Train unit tests
Add local bindep.txt
Remove unused tools/tox_install.sh
3.7.0¶
update git.openstack.org to opendev
Dropping the py35 testing
Remove debtcollector requirement
Update Sphinx requirement
3.6.0¶
Remove unsused tools/tox_install.sh
Handle collections.abc deprecations
Uncap jsonschema
OpenDev Migration Patch
Update master for stable/stein
add python 3.7 unit test job
3.4.0¶
Move test requirements out of runtime requirements
Change openstack-dev to openstack-discuss
3.3.1¶
Update doc/conf.py to avoid warnings with sphinx 1.8
Use templates for cover and lower-constraints
Remove the duplicated word
Fix a symbol error
Create KazooClient with taskflow logger
add lib-forward-testing-python3 test job
add python 3.6 unit test job
add proper pydot3 dependency
import zuul job settings from project-config
Switch to use stestr for unit test
Add pydot test dependency
Remove PyPI downloads
Update reno for stable/rocky
Update various links in docs
3.2.0¶
Remove unused link target
Fix code to support networkx > 1.0
add release notes to README.rst
replace http with https
Update links in README
fix tox python3 overrides
Drop py34 target in tox.ini
Uncap networkx
give pep8 and docs environments all of the dependencies they need
Trivial: update pypi url to new url
Fix doc build
Trivial: Update pypi url to new url
stop using tox_install.sh
only run doc8 as part of pep8 test job
standardize indentation in tox.ini
set default python to python3
don’t let tox_install.sh error if there is nothing to do
Updated from global requirements
add lower-constraints job
Updated from global requirements
Fix invalid json unit test
Update reno for stable/queens
Updated from global requirements
Updated from global requirements
Updated from global requirements
Updated from global requirements
3.1.0¶
Updated from global requirements
Add doc8 to pep8 environment
Use doc/requirements.txt
3.0.1¶
3.0.0¶
Remove setting of version/release from releasenotes
Updated from global requirements
Updated from global requirements
Updated from global requirements
Remove class StopWatch from timing
2.17.0¶
2.16.0¶
Updated from global requirements
Updated from global requirements
Update “indentify” to “identify” in comments
2.15.0¶
Updated from global requirements
Remove method blather in log adapter
Remove kwarg timeout in executor conductor
Updated from global requirements
Avoid log warning when closing is underway (on purpose)
Update reno for stable/pike
Updated from global requirements
2.14.0¶
Updated from global requirements
Update URLs in documents according to document migration
Updated from global requirements
Fix process based executor task proxying-back events
turn on warning-is-error in doc build
switch from oslosphinx to openstackdocstheme
rearrange existing documentation into the new standard layout
Updated from global requirements
2.13.0¶
Updated from global requirements
Fix html_last_updated_fmt for Python3
Replace assertRaisesRegexp with assertRaisesRegex
2.12.0¶
Updated from global requirements
Updated from global requirements
do not allow redis job reclaim by same owner
2.11.0¶
Fix py35 test failure
Stop using oslotest.mockpatch
Updated from global requirements
python3.0 has deprecated LOG.warn
2.10.0¶
Updated from global requirements
Updated from global requirements
Updated from global requirements
Prepare for using standard python tests
Use https instead of http for git.openstack.org
Updated from global requirements
Update reno for stable/ocata
Protect storage better against external concurrent access
2.9.0¶
Remove dep on monotonic
Rename engine analyzer to be named selector
Update author and author-email
Updated from global requirements
Updated from global requirements
Add Constraints support
Show team and repo badges on README
2.8.0¶
Replaces uuid.uuid4 with uuidutils.generate_uuid()
Updated from global requirements
Remove vim header from source files
Fix release notes gate job failure
Updated from global requirements
Use assertIs(Not)None to check for None
Fix typo in tox.ini
Fix broken link
Replace retrying with tenacity
Updated from global requirements
Add reno for release notes management
Updated from global requirements
2.7.0¶
Changed the home-page link
Using assertIsNone() instead of assertIs(None, ..)
Updated from global requirements
Fix a typo in documentation
Fix typo: remove redundant ‘that’
Updated from global requirements
Fix a typo in logging.py
Use method ensure_tree from oslo.utils
Make failure formatter configurable for DynamicLoggingListener
Updated from global requirements
Some classes not define __ne__() built-in function
2.6.0¶
2.5.0¶
Updated from global requirements
Add logging around metadata, ignore tallying + history
2.4.0¶
Updated from global requirements
Start to add a location for contributed useful tasks/flows/more
Change dependency to use flavors
Updated from global requirements
Remove white space between print and ()
Updated from global requirements
Add Python 3.5 classifier and venv
Replace assertEqual(None, *) with assertIsNone in tests
2.3.0¶
Updated from global requirements
remove unused LOG
Fixes: typo error in comments
Updated from global requirements
Fix some misspellings in the function name and descriptions
Updated from global requirements
2.2.0¶
Don’t use deprecated method timeutils.isotime
Add tests to verify kwargs behavior on revert validation
Make tests less dependent on transient state
2.1.0¶
Updated from global requirements
Ensure the fetching jobs does not fetch anything when in bad state
Updated from global requirements
Use the full ‘get_execute_failures’ vs the shortname
Split revert/execute missing args messages
Updated from global requirements
Instead of a multiprocessing queue use sockets via asyncore
Add a simple sanity test for pydot outputting
2.0.0¶
Updated from global requirements
Fix documentation related to missing BaseTask class
Remove deprecated things for 2.0 release
Always used the library packaged mock
1.32.0¶
Attempt to cancel active futures when suspending is underway
Allow for specifying green threaded to parallel engine
Make conductor.stop stop the running engine gracefully
1.31.0¶
Updated from global requirements
Don’t set html_last_updated_fmt without git
Updated from global requirements
Add the ability to skip resolving from activating
Fix export_to_dot for networkx package changes
Ensure upgrade for sqlalchemy is protected by a lock
Add periodic jobboard refreshing (incase of sync issues)
Fallback if git is absent
Allow for revert to have a different argument list from execute
1.30.0¶
Updated from global requirements
Use a automaton machine for WBE request state machine
Sqlalchemy-utils double entry (already in test-requirements.txt)
1.29.0¶
Updated from global requirements
Refactor Atom/BaseTask/Task/Retry class hierarchy
Add missing direct dependency for sqlalchemy-utils
1.28.0¶
Add WBE worker expiry
Some WBE protocol/executor cleanups
Remove need for separate notify thread
Updated from global requirements
Don’t bother scanning for workers if no new messages arrived
Updated from global requirements
Updated from global requirements
Updated from global requirements
Allow cachedproperty to avoid locking
Spice up WBE banner and add simple worker __main__ entrypoint
1.27.0¶
Updated from global requirements
Fix for WBE sporadic timeout of tasks
Add some basic/initial engine statistics
Handle cases where exc_args can’t be serialized as JSON in the WBE
Enable OS_LOG_CAPTURE so that logs can be seen (on error)
Retrieve the store from flowdetails as well, if it exists
Disable oslotest LOG capturing
Updated from global requirements
Updated from global requirements
Use helper function for post-atom-completion work
Ensure that the engine finishes up even under sent-in failures
99 bottles example trace logging was not being output
Add useful/helpful comment to retry scheduler
Updated from global requirements
Updated from global requirements
Replace clear zookeeper python with clear zookeeper bash
Remove stray LOG.blather
1.26.0¶
Some additional engine logging
Replace deprecated library function os.popen() with subprocess
Add comment as to why we continue when tallying edge decider nay voters
Add rundimentary and/or non-optimized job priorities
Allow for alterations in decider ‘area of influence’
Fix wrong usage of iter_utils.unique_seen
Updated from global requirements
Updated from global requirements
Updated from global requirements
Use the retrying lib. to do basic sqlalchemy engine validation
For taskflow patterns don’t show taskflow.patterns prefix
Rename ‘_emit’ -> ‘_try_emit’ since it is best-effort (not ensured)
Cache atom name -> actions and provide accessor function
Quote/standardize atom name output
Use shared util helper for driver name + config extraction
Fix currently broken and inactive mysql tests
Trap and expose exception any ‘args’
Revert “Remove failure version number”
Move all internal blather usage/calls to trace usage/calls
Start rename of BLATHER -> TRACE
Add ability of job poster/job iterator to wait for jobs to complete
Updated from global requirements
Use ‘match_type’ utility function instead of staticmethod
Remove failure version number
Translate kazoo exceptions into job equivalents if register_entity fails
Change name of misc.ensure_dict to misc.safe_copy_dict
Avoid recreating notify details for each dispatch iteration
fix doc change caused by the change of tooz
Deprecated tox -downloadcache option removed
Updated from global requirements
Add some useful commentary on rebinding processes
Use small helper routine to fetch atom metadata entries
Remove ‘MANIFEST.in’
Pass through run timeout in engine run()
Change engine ‘self._check’ into a decorator
1.25.0¶
Move validation of compiled unit out of compiler
Allow provided flow to be empty
Move engine options extraction to __init__ methods
Updated from global requirements
Updated from global requirements
Convert executor proxied engine options into their correct type
Enable conversion of the tree nodes into a digraph
Use the misc.ensure_dict helper in conductor engine options saving
Add optional ‘defer_reverts’ behavior
Add public property from storage to flowdetail.meta
Adding notification points for job completion
Remove python 2.6 and cleanup tox.ini
Correctly apply deciders across flow boundaries
Move ‘convert_to_timeout’ to timing type as a helper function
Use conductor entity class constant instead of raw string
Add a executor backed conductor and have existing impl. use it
Add flow durations to DurationListener
Update docstrings on entity type
Move ‘fill_iter’ to ‘iter_utils.fill’
1.24.0¶
Updated from global requirements
Updated from global requirements
Register conductor information on jobboard
Add atom priority ability
Add validation of base exception type(s) in failure type
Fix order of assertEqual for unit.test_*
Fix order of assertEqual for unit.worker_based
Fix order of assertEqual for unit.persistence
Fix order of assertEqual for unit.patterns
Fix order of assertEqual for unit.jobs
Fix order of assertEqual for unit.action_engine
1.23.0¶
Updated from global requirements
feat: add max_dispatches arg to conductor’s run
Ensure node ‘remove’ and ‘disassociate’ can not be called when frozen
Add in-memory backend delete() in recursive/non-recursive modes
Use batch ‘get_atoms_states’ where we can
Use automaton’s converters/pydot
Make more of the WBE logging and ‘__repr__’ message more useful
Fix bad sphinx module reference
Relabel internal engine ‘event’ -> ‘outcome’
No need for Oslo Incubator Sync
Use the node built-in ‘dfs_iter’ instead of recursion
1.22.0¶
Simplify flow action engine compilation
Fix ‘dependened upon’ spelling error
docs - Set pbr warnerrors option for doc build
Rename ‘history’ -> ‘Release notes’
Remove dummy/placeholder ‘ChangeLog’ as its not needed
Remove ./taskflow/openstack/common as it no longer exists
Remove quotes from subshell call in bash script
Refactor common parts of ‘get_maybe_ready_for’ methods
Fix the sphinx build path in .gitignore file
Change ignore-errors to ignore_errors
Use graphs as the underlying structure of patterns
Updated from global requirements
Fix ‘_cache_get’ multiple keyword argument name overlap
Use the sqlalchemy-utils json type instead of our own
1.21.0¶
Updated from global requirements
Fix how the dir persistence backend was not listing logbooks
Explain that jobs arch. diagram is only for zookeeper
1.20.0¶
Updated from global requirements
iter_nodes method added to flows
Updated from global requirements
Use ‘iter_utils.count’ to determine how many unfinished nodes left
Fix flow states link
Avoid running this example if zookeeper is not found
Updated from global requirements
Have the storage class provide a ‘change_flow_state’ method
1.19.0¶
Updated from global requirements
Updated from global requirements
Add nicely made task structural diagram
Updated from global requirements
Remove some temporary variables not needed
Only remove all ‘next_nodes’ that were done
Fix busted stevedore doc(s) link
Extend and improve failure logging
Improve docstrings in graph flow to denote exceptions raised
Enable testr OS_DEBUG to be TRACE(blather) by default
Updated from global requirements
Show intermediary compilation(s) when BLATHER is enabled
1.18.0¶
Give the GC more of a break with regard to cycles
Base class for deciders
Remove extra runner layer and just use use machine in engine
Updated from global requirements
.gitignore update
Avoid adding 1 to a failure (if it gets triggered)
Replace the tree ‘pformat()’ recursion with non-recursive variant
Fix seven typos and one readability on taskflow documentation
1.17.0¶
Bump futurist and remove waiting code in taskflow
Use the action engine ‘_check’ helper method
Modify listeners to handle the results now possible from revert()
Remove no longer used ‘_was_failure’ static method
Remove legacy py2.6 backwards logging compat. code
Updated from global requirements
Fix lack of space between functions
Create and use a serial retry executor
Just link to the worker engine docs instead of including a TOC inline
Link to run() method in engines doc
Add ability to reset an engine via a `reset` method
1.16.0¶
Updated from global requirements
Use ‘addCleanup’ instead of ‘tearDown’ in engine(s) test
Update ‘make_client’ kazoo docs and link to them
Remove **most** usage of taskflow.utils in examples
Move doc8 to being a normal test requirement in test-requirements.txt
Updated from global requirements
Found another removal_version=? that should be removal_version=2.0
Add deprecated module(s) for prior FSM/table code-base
Replace internal fsm + table with automaton library
Remove direct usage of timeutils overrides and use fixture
1.15.0¶
Provide a deprecated alias for the now removed stop watch class
Update all removal_version from being ? to being 2.0
Add deprecated and only alias modules for the moved types
Unify the zookeeper/redis jobboard iterators
Updated from global requirements
Run the ‘99_bottles.py’ demo at a fast rate when activated
Use io.open vs raw open
Retain atom ‘revert’ result (or failure)
Update the version on the old/deprecated logbook module
Add docs for u, v, decider on graph flow link method
Fix mock calls
Remove setup.cfg ‘requires-python’ incorrect entry
Compile lists of retry/task atoms at runtime compile time
Integrate futurist (and **remove** taskflow originating code)
Allow the 99_bottles.py demo to run in BLATHER mode
Make currently implemented jobs use @functools.total_ordering
Add more useful `__str__` to redis job
Show job posted and goodbye in 99_bottles.py example
Rename logbook module -> models module
Notify on the individual engine steps
1.14.0¶
Expose strategies so doc generation can easily pick them up
Denote mail subject should be ‘[Oslo][TaskFlow]’
Add support for conditional execution
Use encodeutils for exception -> string function
Updated from global requirements
Build-out + test a redis backed jobboard
0.13.0¶
Just make the compiler object at __init__ time
Remove kazoo hack/fix for issue no longer needed
Add history.rst that uses generated ‘ChangeLog’ file
Add docstrings on runtime objects methods and link to them in docs
0.12.0¶
Updated from global requirements
Update states comment to refer to task section
Updated from global requirements
Remove 2.6 classifier + 2.6 compatibility code
Remove reference to ‘requirements-pyN.txt’ files
Add smarter/better/faster impl. of `ensure_atoms`
Add bulk `ensure_atoms` method to storage
Make it possible to see the queries executed (in BLATHER mode)
Add doc warning to engine components
Perform a few optimizations to decrease persistence interactions
Handle conductor ctrl-c more appropriately
Cache the individual atom schedulers at compile time
Split-off the additional retry states from the task states
Use the `excutils.raise_with_cause` after doing our type check
Updated from global requirements
Use monotonic lib. to avoid finding monotonic time function
Document more of the retry subclasses special keyword arguments
0.11.0¶
Address concurrent mutation of sqlalchemy backend
Add indestructible 99 bottles of beer example
Use alembic upgrade function/command directly
Updated from global requirements
Remove usage of deprecated ‘task_notifier’ property in build_car example
Add `simple_linear_listening` example to generated docs
Handy access to INFO level
Switch badges from ‘pypip.in’ to ‘shields.io’
Adding a revert_all option to retry controllers
A few jobboard documentation tweaks
Use sphinx deprecated docstring markup
Use a class constant for the default path based backend path
Updated from global requirements
Remove example not tested
Make the default file encoding a class constant with a docstring
Use a lru cache to limit the size of the internal file cache
Updated from global requirements
Use hash path lookup vs path finding
Remove all ‘lock_utils’ now that fasteners provides equivalents
Add a new `ls_r` method
Updated from global requirements
Refactor machine builder + runner into single unit
Replace lock_utils lock(s) with fasteners package
Updated from global requirements
Use shared ‘_check’ function to check engine stages
Remove a couple more useless ‘pass’ keywords found
Add a test that checks for task result visibility
Remove testing using persistence sqlalchemy backend with ‘mysqldb’
Remove customized pyX.Y tox requirements
Updated from global requirements
Allow same deps for requires and provides in task
Remove ‘pass’ usage not needed
Only show state transitions to logging when in BLATHER mode
Fix updated_at column of sqlalchemy tables
Remove script already nuked from oslo-incubator
Ensure path_based abstract base class is included in docs
Beef up docs on the logbook/flow detail/atom details models
Remove custom py26/py27 tox venvs no longer used
Executors come in via options config, not keyword arguments
Use newer versions of futures that adds exception tracebacks
Ensure empty paths raise a value error
Remove listener stack and replace with exit stack
Expose action engine no reraising states constants
Chain a few more exception raises that were previously missed
Expose in memory backend split staticmethod
Updated from global requirements
Remove tox py33 environment no longer used
Avoid creating temporary removal lists
0.10.1¶
Avoid trying to copy tasks results when cloning/copying
Avoid re-normalizing paths when following links
Add a profiling context manager that can be easily enabled
Updated from global requirements
0.10.0¶
Remove validation of state on state read property access
Make the default path a constant and tweak class docstring
Avoid duplicating exception message
Add speed-test tools script
Speed up memory backend via a path -> node reverse mapping
Updated from global requirements
Fix a typo in taskflow docs
Small refactoring of ‘merge_uri’ utility function
Fix post coverage job option not recognized
Refactor/reduce shared ‘ensure(task/retry)’ code
Move implementations into there own sub-sections
Remove run_cross_tests.sh
Move zookeeper jobboard constants to class level
Retain chain of missing dependencies
Expose fake filesystem ‘join’ and ‘normpath’
Add + use diagram explaining retry controller area of influence
Add openclipart.org conductor image to conductor docs
Use oslo_utils eventletutils to warn about eventlet patching
Test more engine types in argument passing unit test
Add a conductor running example
Replace more instance(s) of exception chaining with helper
Avoid attribute error by checking executor for being non-none
0.9.0¶
Validate correct exception subclass in ‘raise_with_cause’
Remove link to kazoo eventlet handler
Add states generating venv and use pydot2
Add strict job state transition checking
Uncap library requirements for liberty
Have reset state handlers go through a shared list
Add job states in docs + states in python
Expose r/o listener callback + details filter callback
Expose listener notification type + docs
Ensure listener args are always a tuple/immutable
Include the ‘dump_memory_backend’ example in the docs
Make resolution/retry strategies more clear and better
Rename notifier ‘listeners’ to ‘topics’
Mention link to states doc in notify state transitions
Ensure we don’t get stuck in formatting loops
Add note about thread safety of fake filesystem
Have the notification/listener docs match other sections
Put semantics preservation section into note block
Note that the traditional mode also avoids this truncation issue
Avoid going into causes of non-taskflow exceptions
Use the ability to chain exceptions correctly
Add a example showing how to share an executor
Shrink the bookshelf description
Remove link about implementing job garbage binning
Make the storage layer more resilent to failures
Put the examples/misc/considerations under a new section
Add a suspension engine section
0.8.1¶
Switch back to maxdepth 2
Allow ls() to list recursively (using breadth-first)
Make an attempt at having taskflow exceptions print causes better
fix renamed class to call super correctly
Turn ‘check_who’ into a decorator
Use ‘node’ terminology instead of ‘item’ terminology
Remove 11635 bug reference
Allow providing a node stringify function to tree pformat
Add in memory filesystem clearing
Just unify having a single requirements.txt file
Fix a couple of spelling and grammar errors
Add memory backend get() support
Make the graph ‘_unsatisfied_requires’ be a staticmethod
Add more comments to fake in-memory filesystem
Add a set of tests to the in memory fake filesystem
0.8.0¶
Adding test to improve CaptureListener coverage
Prefer posixpath to os.path
By default use a in memory backend (when none is provided)
Allow using shallow copy instead of deep copy
Move to the newer debtcollector provided functions
Move to using the oslo.utils stop watch
Updated from global requirements
Ensure thread-safety of persistence dir backend
Ensure we are really setup before being connected
Ensure docstring on storage properties
Expose the storage backend being used
Use iteration instead of list(s) when extracting scopes
Use binary/encode decode helper routines in dir backend
Rename memory backend filesystem -> fake filesystem
Just let the future executors handle the max workers
Always return scope walker instances from `fetch_scopes_for`
Give the GC a break
Use the class name instead of the TYPE property in __str__
Just use the class name instead of TYPE constant
Ensure we have a ‘coverage-package-name’
Attempt to extract traceback from exception
Use compatible map and update map/reduce task docs
Update engine docs with new validation stage
Ensure we register & deregister conductor listeners
Rename attribute ‘_graph’ to ‘_execution_graph’
Add a log statement pre-validation that dumps graph info
Have this example exit non-zero if incorrect results
Use a collections.namedtuple for the request work unit
Some small wbe engine doc tweaks
Add newline to avoid sphinx warning
Allow passing ‘many_handler’ to fetch_all function
Ensure event time listener is in listeners docs
Add a in-memory backend dumping example
Added a map and a reduce task
Restructure the in-memory node usage
Switch to non-namespaced module imports
Allow the storage unit to use the right scoping strategy
Just use the local conf variable
Put underscore in-front of alchemist helper
lazy loading for logbooks and flowdetails
Allow backend connection config (via fetch) to be a string
Add + use failure json schema validation
Use ordered[set/dict] to retain ordering
Allow injected atom args to be persisted
add _listeners_from_job method to Conductor base
update uses of TimingListener to DurationListener
Added EventTimeListner to record when events occur
added update_flow_metadata method to Storage class
Retain nested causes where/when we can
Denote issue 17911 has been merged/accepted
Persistence backend refactor
Remove support for 3.3
Writers can now claim a read lock in ReaderWriterLock
Add another probabilistic rw-lock test
Add + use read/write lock decorators
Add no double writers thread test
Use condition context manager instead of acquire/release
Remove condition acquiring for read-only ops
Set a no-op functor when none is provided
Ensure needed locks is used when reading/setting intention
Specialize checking for overlaps
Use links instead of raw block quotes
Rename the timing listeners to duration listeners
Add a bookshelf developer section
Ensure the thread bundle stops in last to first order
Add warning about transient arguments and worker-based-engines
Ensure ordered set is pickleable
Add node removal/disassociate functions
Add a fully functional orderedset
Make the worker banner template part of the worker class
Use compilation helper objects
Allow node finding to not do a deep search
Add a frozen checking decorator
Tweak functor used to find flatteners/storage routines
Add specific scoping documentation
add jobboard trash method
Provide more contextual information about invalid periodics
Fix lookup scoping multi-match ordering
Stick to one space after a period
Refactor parts of the periodic worker
Use oslo.utils encodeutils for encode/decode functions
Bring over pretty_tox.sh from nova/heat/others
Tweak some of the types thread safety docstrings
Add pypi link badges
Switch the note about process pool executor to warning
Chain exceptions correctly on py3.x
Updated from global requirements
Remove WBE experimental documentation note
Use the enum library for the retry strategy enumerations
Use debtcollector library to replace internal utility
add get_flow_details and get_atom_details to all backends
Tweaks to atom documentation
Update Flow::__str__
Add todo note for kombu pull request
Move ‘provides’ and ‘name’ to instance attributes
Allow loading conductors via entrypoints
0.7.1¶
Revert “Add retries to fetching the zookeeper server version”
Allow turning off the version check
adding check for str/unicode type in requires
Make the dispatcher handler be an actual type
Add retries to fetching the zookeeper server version
Remove duplicate ‘the’ and link to worker engine section
Remove delayed decorator and replace with nicer method
Fix log statement
Make the atom class an abstract class
Improve multilock class and its associated unit test
Mark conductor ‘stop’ method deprecation kwarg with versions
Move to hacking 0.10
catch NotFound errors when consuming or abandoning
Use the new table length constants
Improve upon/adjust/move around new optional example
Clarify documentation related to inputs
Docstrings should document parameters return values
Let the multi-lock convert the provided value to a tuple
Map optional arguments as well as required arguments
Add a BFS tree iterator
DFS in right order when not starting at the provided node
Rework the sqlalchemy backend
Modify stop and add wait on conductor to prevent lockups
Default to using a thread-safe storage unit
Add warning to sqlalchemy backend size limit docs
Updated from global requirements
Use a thread-identifier that can’t easily be recycled
Use a notifier instead of a direct property assignment
Tweak the WBE diagram (and present it as an svg)
Remove duplicate code
Improved diagram for Taskflow
Bump up the env_builder.sh to 2.7.9
Add a capturing listener (for test or other usage)
Add + use a staticmethod to fetch the immediate callables
Just directly access the callback attributes
Use class constants during pformatting a tree node
0.7.0¶
Abstract out the worker finding from the WBE engine
Add and use a nicer kombu message formatter
Remove duplicated ‘do’ in types documentation
Use the class defined constant instead of raw strings
Use kombu socket.timeout alias instead of socket.timeout
Stopwatch usage cleanup/tweak
Add note about publicly consumable types
Add docstring to wbe proxy to denote not for public use
Use monotonic time when/if available
Updated from global requirements
Link WBE docs together better (especially around arguments)
Emit a warning when no routing keys provided on publish()
Center SVG state diagrams
Use importutils.try_import for optional eventlet imports
Shrink the WBE request transition SVG image size
Add a thread bundle helper utility + tests
Make all/most usage of type errors follow a similar pattern
Leave use-cases out of WBE developer documentation
Allow just specifying ‘workers’ for WBE entrypoint
Add comments to runner state machine reaction functions
Fix coverage environment
Use explicit WBE worker object arguments (instead of kwargs)
WBE documentation tweaks/adjustments
Add a WBE request state diagram + explanation
Tidy up the WBE cache (now WBE types) module
Fix leftover/remaining ‘oslo.utils’ usage
Show the failure discarded (and the future intention)
Use a class provided logger before falling back to module
Use explicit WBE object arguments (instead of kwargs)
Fix persistence doc inheritance hierarchy
The gathered runtime is for failures/not failures
add clarification re parallel engine
Increase robustness of WBE producer/consumers
Move implementation(s) to there own sections
Move the jobboard/job bases to a jobboard/base module
Have the serial task executor shutdown/restart its executor
Mirror the task executor methods in the retry action
Add back a ‘eventlet_utils’ helper utility module
Use constants for runner state machine event names
Remove ‘SaveOrderTask’ and test state in class variables
Provide the stopwatch elapsed method a maximum
Fix unused and conflicting variables
Switch to using ‘oslo_serialization’ vs ‘oslo.serialization’
Switch to using ‘oslo_utils’ vs ‘oslo.utils’
Add executor statistics
Use oslo.utils reflection for class name
Add split time capturing to the stop watch
Use platform neutral line separator(s)
Create and use a multiprocessing sync manager subclass
Use a single sender
Updated from global requirements
Include the ‘old_state’ in all currently provided listeners
Update the README.rst with accurate requirements
Include docstrings for parallel engine types/strings supported
The taskflow logger module does not provide a logging adapter
Send in the prior atom state on notification of a state change
Pass a string as executor in the example instead of an executor
Updated from global requirements
Fix for job consumption example using wrong object
0.6.1¶
Remove need to inherit/adjust netutils split
Allow specifying the engine ‘executor’ as a string
Disallowing starting the executor when worker running
Use a single shared queue for an executors lifecycle
Avoid creating a temporary list(s) for tree type
Update statement around stopwatch thread safety
Register with ‘ANY’ in the cloned process
Add edge labels for engine states
Remove less than useful action_engine __str__
Ensure manager started/shutdown/joined and reset
Return the same namedtuple that the future module returns
Add a simplistic hello world example
Get event/notification sending working correctly
Move the engine scoping test to its engines test folder
Get the basics of a process executor working
Move the persistence base to the parent directory
Correctly trigger ‘on_exit’ of starting/initial state
0.6.0¶
Add an example which shows how to send events out from tasks
Move over to using oslo.utils [reflection, uuidutils]
Rework the in-memory backend
Updated from global requirements
Add a basic map/reduce example to show how this can be done
Add a parallel table mutation example
Add a ‘can_be_registered’ method that checks before notifying
Base task executor should provide ‘wait_for_any’
Replace autobind with a notifier module helper function
Cleanup some doc warnings/bad/broken links
Use the notifier type in the task class/module directly
Use a tiny clamp helper to clamp the ‘on_progress’ value
Retain the existence of a ‘EngineBase’ until 0.7 or later
Remove the base postfix from the internal task executor
Remove usage of listener base postfix
Add a moved_inheritable_class deprecation helper
Avoid holding the lock while scanning for existing jobs
Remove the base postfix for engine abstract base class
Avoid popping while another entity is iterating
Updated from global requirements
Use explict ‘attr_dict’ when adding provider->consumer edge
Properly handle and skip empty intermediary flows
Ensure message gets processed correctly
Just assign a empty collection instead of copy/clear
Remove rtype from task clone() doc
Add and use a new simple helper logging module
Have the sphinx copyright date be dynamic
Add appropriate links into README.rst
Use condition variables using ‘with’
Use an appropriate ``extract_traceback`` limit
Allow all deprecation helpers to take a stacklevel
Correctly identify stack level in ``_extract_engine``
Stop returning atoms from execute/revert methods
Have tasks be able to provide copy() methods
Allow stopwatches to be restarted
Ensure that failures can be pickled
Rework pieces of the task callback capability
Just use 4 spaces for classifier indents
Move atom action handlers to there own subfolder/submodule
Workflow documentation is now in infra-manual
Ensure frozen attribute is set in fsm clones/copies
Fix split on “+” for connection strings that specify dialects
Update listeners to ensure they correctly handle all atoms
Allow for the notifier to provide a ‘details_filter’
Be explicit about publish keyword arguments
Some package additions and adjustments to the env_builder.sh
Cache immutable visible scopes in the runtime component
Raise value errors instead of asserts
Add a claims listener that connects job claims to engines
Split the scheduler into sub-schedulers
Use a module level constant to provide the DEFAULT_LISTEN_FOR
Move the _pformat() method to be a classmethod
Add link to issue 17911
Avoid deepcopying exception values
Include documentation of the utility modules
Use a metaclass to dynamically add testcases to example runner
Remove default setting of ‘mysql_traditional_mode’
Move scheduler and completer classes to there own modules
Ensure that the zookeeper backend creates missing atoms
Use the deprecation utility module instead of warnings
Tweaks to setup.cfg
Add a jobboard high level architecture diagram
Mark ‘task_notifier’ as renamed to ‘atom_notifier’
Revert wrapt usage until further notice
Updated from global requirements
Add a history retry object, makes retry histories easier to use
Format failures via a static method
When creating daemon threads use the bundled threading_utils
Ensure failure types contain only immutable items
Mark ‘task_notifier’ as renamed to ‘atom_notifier’
Use wrapt to provide the deprecated class proxy
Updated from global requirements
Updated from global requirements
Updated from global requirements
Reduce the worker-engine joint testing time
Link bug in requirements so people understand why pbr is listed
Updated from global requirements
Use standard threading locks in the cache types
Handle the case where ‘_exc_type_names’ is empty
Add pbr to installation requirements
Updated from global requirements
Remove direct usage of the deprecated failure location
Fix the example ‘default_provides’
Use constants for retry automatically provided kwargs
Remove direct usage of the deprecated notifier location
Remove attrdict and just use existing types
Use the mock that finds a working implementation
Add a futures type that can unify our future functionality
Bump the deprecation version number
Use and verify event and latch wait() return using timeouts
Deprecate `engine_conf` and prefer `engine` instead
Use constants for link metadata keys
Bump up the sqlalchemy version for py26
Hoist the notifier to its own module
Move failure to its own type specific module
Use constants for revert automatically provided kwargs
Improve some of the task docstrings
We can now use PyMySQL in py3.x tests
Updated from global requirements
Add the database schema to the sqlalchemy docs
Change messaging from handler connection timeouts -> operation timeouts
Switch to a custom NotImplementedError derivative
Allow the worker banner to be written to an arbitrary location
Update engine class names to better reflect there usage
0.5.0¶
Avoid usage of six.moves in local functions
Refactor parts of the job lock/job condition zookeeper usage
Make it so that the import works for older versions of kombu
Rework the state documentation
Updated from global requirements
Add a more dynamic/useful logging listener
Use timeutils functions instead of misc.wallclock
Expose only `ensure_atom` from storage
Adjust docs+venv tox environments requirements/dependencies
Increase robustness of WBE message and request processing
Adjust the WBE log levels
Use the features that the oslotest mock base class provides
Use oslotest to provide our base test case class
Jobboard example that show jobs + workers + producers
Adjust on_job_posting to not hold the lock while investigating
Bring in a newer optional eventlet
Move some of the custom requirements out of tox.ini
Document more function/class/method params
Stop using intersphinx
Expand toctree to three levels
Documentation cleanups and tweaks
Fix multilock concurrency when shared by > 1 threads
Increase/adjust the logging of the WBE response/send activities
Color some of the states depending on there meaning
Switch to using oslo.utils and oslo.serialization
Typos “searchs”
Update the requirements-py2.txt file
Remove no longer needed r/w lock interface base class
Updated from global requirements
Better handle the tree freeze method
Ensure state machine can be frozen
Link a few of the classes to implemented features/bugs in python
Add a timing listener that also prints the results
Remove useless __exit__ return
Example which shows how to move values from one task to another
Mention issue with more than one thread and reduce workers
Add a mandelbrot parallel calculation WBE example
Add existing types to generated documentation
Remove the dependency on prettytable
Work toward Python 3.4 support and testing
Add a state machine copy() method
Update the state graph builder to use state machine type
Add a docs virtualenv
Reduce unused tox environments
0.4.0¶
Add a couple of scope shadowing test cases
Relax the graph flow symbol constraints
Relax the unordered flow symbol constraints
Relax the linear flow symbol constraints
Revamp the symbol lookup mechanism
Be smarter about required flow symbols
Update oslo-incubator to 32e7f0b56f52742754
Translate the engine runner into a well defined state-machine
Raise a runtime error when mixed green/non-green futures
Ensure the cachedproperty creation/setting is thread-safe
warn against sorting requirements
Updated from global requirements
Update transitioning function name to be more understandable
Move parts of action engine tests to a subdirectory
Tweak engine iteration ‘close-up shop’ runtime path
Use explicit WBE request state transitions
Reject WBE messages if they can’t be put in an ack state
Make version.py handle pbr not being installed
Cleanup WBE example to be simpler to understand
Use __qualname__ where appropriate
Updated from global requirements
Updated from global requirements
Make the WBE worker banner information more meaningful
Have the dispatch_job function return a future
Expand documention on failures and wrapped failures types
Allow worker count to be specified when no executor provided
Remove sphinx examples emphasize-lines
Split requirements into py2 and py3 files
Update oslo-incubator to 037dee004c3e2239
Remove db locks and use random db names for tests
Allow WBE request transition timeout to be dynamic
Avoid naming time type module the same as a builtin
LOG which requeue filter callback failed
Add a pformat() failure method and use it in the conductor
add pre/post execute/retry callbacks to tasks
Use checked_commit() around consume() and abandon()
Use a check + create transaction when claiming a job
Improve WBE testing coverage
Add basic WBE validation sanity tests
WBE request message validation
WBE response message validation
WBE notification message validation
Allow handlers to provide validation callables
Use a common message dispatcher
Use checked commit when committing kazoo transactions
Enable hacking checks H305 and H307 in tox.ini template
Fixes unsorted dicts and sets in doctests
README.rst: Avoid using non-ascii character
Updated from global requirements
Add a sample script that can be used to build a test environment
Enabled hacking checks H305 and H307
Bump hacking to version 0.9.2
Allow a jobs posted book to be none by default
Cleanup some of the example code & docs
Make greenexecutor not keep greenthreads active
Add the arch/big picture omnigraffle diagram
Remove pbr as a runtime dependency
Use the `state_graph.py` for all states diagrams
Make the examples documentation more relevant
Raise NotImplementedError instead of NotImplemented
Move the stopwatch tests to test_types
Remove need to do special exception catching in parse_uri
Update oslo incubator code to commit 0b02fc0f36814968
Fix the section name in CONTRIBUTING.rst
Add a conductor considerations section
Make the expiring cache a top level cache type
Use `flow_uuid` and `flow_name` from storage
Fix traces left in zookeeper
Clarify locked decorator is for instance methods
Extract the state changes from the ensure storage method
Create a top level time type
Simplify identity transition handling for tasks and retries
Remove check_doc.py and use doc8
Remove functions created for pre-six 1.7.0
Add a tree type
Make intentions a tuple (to denote immutability)
Updated from global requirements
Add example for pseudo-scoping
Fix E265 hacking warnings
Fix doc which should state fetch() usage
Adjust sphinx requirement
Upgrade hacking version and fix some of the issues
Denote that other projects can use this library
Remove misc.as_bool as oslo provides an equivalent
Update zake to requirements version
0.3.21¶
Rename additional to general/higher-level
Sync our version of the interprocess lock
Increase usefulness of the retry component compile errors
Switch to a restructuredtext README file
Create a considerations section
Include the function name on internal errors
Add in default transaction isolation levels
Allow the mysql mode to be more than just TRADITIONAL
Make the runner a runtime provided property
Rename inject_task_args to inject_atom_args
Rename the graph analyzer to analyzer
Provide the compilation object instead of just a part of it
Ensure cachedproperty descriptor picks up docstrings
0.3¶
Warn about internal helper/utility usage
Rename to atom from task
Invert the conductor stop() returned result
Move flattening to the action engine compiler
Increase the level of usefulness of the dispatching logging
Avoid forcing engine_conf to a dict
Allow for two ways to find a flow detail in a job for a conductor
Add docs related to the new conductor feature
Add docstring describing the inject instance variable
Finish factoring apart the graph_action module
Update sphinx pin from global requirements
Fix docstring list format
Allow indent text to be passed in
Factor out the on_failure to a mixin type
Use a name property setter instead of a set_name method
Adds a single threaded flow conductor
add the ability to inject arguments into tasks at task creation
Synced jsonutils from oslo-incubator
Remove wording issue (track does not make sense here)
Fix case of taskflow in docs
Put the job external wiki link in a note section
Rework atom documentation
Add doc link to examples
Rework the overview of the notification mechanism
Standardize on the same capitalization pattern
Regenerate engine-state sequence diagram
Add source of engine-state sequence diagram
Add kwarg check_pending argument to fake lock
Add a example which uses the run_iter function in a for loop
Fix error string interpolation
Rename t_storage to atom_storage
Create and use a new compilation module
Add engine state diagram
Add tests for the misc.cachedproperty descriptor
Complete the cachedproperty descriptor protocol
Don’t create fake LogBook when we can not fetch one
Use futures wait() when possible
Use /taskflow/flush-test in the flush function
Add a reset nodes function
Default the impl_memory conf to none
Fix spelling mistake
Add a helper tool which clears zookeeper test dirs
Add a zookeeper jobboard integration test
Cleanup zookeeper integration testing
Use a more stable flush method
Remove the _clear method and do not reset the job_watcher
Allow command and connection retry configuration
Check documentation for simple style requirements
Add an example which uses the run iteration functionality
Implement run iterations
Put provides and requires code to basic Flow
Allow the watcher to re-register if the session is lost
Add a new wait() method that waits for jobs to arrive
Add a cachedproperty descriptor
Add an example for the job board feature
Engine _cls postfix is not correct
Pass executor via kwargs instead of config
Allow the WBE to use a preexisting executor
Tweaks to object hiearchy diagrams
Adjust doc linking
Medium-level docs on engines
Add docs for the worker based engine (WBE)
Updated from global requirements
Move from generator to iterator for iterjobs
Add a jobboard fetching context manager
Wrap the failure to load in the not found exception
Update jobboard docs
Synced jsonutils from oslo-incubator
Remove persistence wiki page link
Load engines with defined args and provided kwargs
Integrate urlparse for configuration augmentation
Fix “occured” -> “occurred”
Documentation tune-ups
Fix spelling error
Add a resumption strategy doc
Docs and cleanups for test_examples runner
Skip loading (and failing to load) lock files
Add a persistence backend fetching context manager
Add a example that activates a future when a result is ready
Fix documentation spelling errors
Add a job consideration doc
Add last_modified & created_on attributes to jobs
Allow jobboard event notification
Use sequencing when posting jobs
Add a directed graph type (new types module)
Add persistence docs + adjustments
Updated from global requirements
Stings -> Strings
Be better at failure tolerance
Ensure example abandons job when it fails
Add docs for jobs and jobboards
Get persistence backend via kwargs instead of conf
Allow fetching jobboard implementations
Reuse already defined variable
More keywords & classifier topics
Allow transient values to be stored in storage
Doc adjustments
Move the daemon thread helper function
Create a periodic worker helper class
Fix not found being raised when iterating
Allow for only iterating over the most ‘fresh’ jobs
Updated from global requirements
Update oslo-incubator to 46f2b697b6aacc67
import run_cross_tests.sh from incubator
Exception in worker queue thread
Avoid holding the state lock while notifying
0.2¶
Allow atoms to save their own state/result
Use correct exception in the timing listener
Add a engine preparation stage
Decrease extraneous logging
Handle retry last_results/last_failure better
Improve documentation for engines
Worker executor adjustments
Revert “Move taskflow.utils.misc.Failure to its own module”
Move taskflow.utils.misc.Failure to its own module
Leave the execution_graph as none until compiled
Move state link to developer docs
Raise error if atom asked to schedule with unknown intention
Removed unused TIMED_OUT state
Rework documentation of notifications
Test retry fails on revert
Exception when scheduling task with invalid state
Fix race in worker-based executor result processing
Set logbook/flowdetail/atomdetail meta to empty dict
Move ‘inputs and outputs’ to developers docs
tests: Discover absence of zookeeper faster
Fix spelling mistake
Should be greater or equal to zero and not greater than
Persistence cleanup part one
Run worker-based engine tests faster
SQLAlchemy requirements put in order
Add timeout to WaitForOneFromTask
Use same code to reset flow and parts of it
Optimize dependency links in flattening
Adjust the exception hierachy
docs: Links to methods on arguments and results page
Add __repr__ method to Atom
Flattening improvements
tests: Fix WaitForOneFromTask constructor parameter introspection
Rework graph flow unit tests
Rewrite assertion for same elements in sequences
Unit tests for unordered flow
Linear flow: mark links and rework unit tests
Drop indexing operator from linear flow
Drop obsolete test_unordered_flow
Iteration over links in flow interface
Add a timeout object that can be interrupted
Avoid shutting down of a passed executor
Add more tests for resumption with retry
Improve logging for proxy publish
Small documentation fix
Improve proxy publish method
Add Retry to developers documentation
Move flow states to developers documentation
Remove extraneous vim configuration comments
Make schedule a proper method of GraphAction
Simplify graph analyzer interface
Test storage with memory and sqlite backends
Fix few minor spelling errors
Fix executor requests publishing bug
Flow smart revert with retry controller
Add atom intentions for tasks and retries
[WBE] Collect information from workers
Add tox environment for pypy
docs: Add inheritance diagram to exceptions documentation
Adjust logging levels and usage to follow standards
Introduce message types for WBE protocol
Add retry action to execute retries
Extend logbook and storage to work with retry
Add retry to execution graph
Add retry to Flow patterns
Add base class for Retry
Update request `expired` property docsting
docs: Add page describing atom arguments and results
docs: Improve BaseTask method docstrings
Remove extra quote symbol
docs: Relative links improvements
docs: Ingore ‘taskflow.’ prefix when sorting module index
Update comment + six.text_type instead of str for name
Avoid calling callbacks while holding locks
Rename remote task to request
Rework proxy publish functionality
Updated from global requirements
Use message.requeue instead of message.reject
Lock test tweaks
Move endpoint subclass finding to reflection util
Correct LOG.warning in persistence utils
Introduce remote tasks cache for worker-executor
Worker-based engine clean-ups
A few worker-engine cleanups
Add a delay before releasing the lock
Allow connection string to be just backend name
Get rid of openstack.common.py3kcompat
Clean-up several comments in reflection.py
Fix try_clean not getting the job_path
Updated from global requirements
Rename uuid to topic
Fixups for threads_count usage and logging
Use the stop watch utility instead of custom timing
Unify usage of storage error exception type
Add zookeeper job/jobboard impl
Updated from global requirements
Removed copyright from empty files
Remove extraneous vim configuration comments
Use six.text_type() instead of str() in sqlalchemy backend
Fix dummy lock missing pending_writers method
Move some common/to be shared kazoo utils to kazoo_utils
Switch to using the type checking decode_json
Fix few spelling and grammar errors
Fixed spelling error
Run action-engine tests with worker-based engine
Message-oriented worker-based flow with kombu
Check atom doesn’t provide and return same values
Fix command for pylint tox env
Remove locale overrides form tox template
Reduce test and optional requirements to global requirements
Rework sphinx documentation
Remove extraneous vim configuration comments
Sync with global requirements
Instead of doing set diffing just partition when state checking
Add ZooKeeper backend to examples
Storage protects lower level backend against thread safety
Remove tox locale overrides
Update .gitreview after repo rename
Small storage tests clean-up
Support building wheels (PEP-427)
0.1.3¶
Add validate() base method
Fix deadlock on waiting for pending_writers to be empty
Rename self._zk to self._client
Use listener instead of AutoSuspendTask in test_suspend_flow
Use test utils in test_suspend_flow
Use reader/writer locks in storage
Allow the usage of a passed in sqlalchemy engine
Be really careful with non-ascii data in exceptions/failures
Run zookeeper tests if localhost has a compat. zookeeper server
Add optional-requirements.txt
Move kazoo to testenv requirements
Unpin testtools version and bump subunit to >=0.0.18
Remove use of str() in utils.misc.Failure
Be more resilent around import/detection/setup errors
Some zookeeper persistence improvements/adjustments
Add a validate method to dir and memory backends
Update oslo copy to oslo commit 39e1c5c5f39204
Update oslo.lock from incubator commit 3c125e66d183
Refactor task/flow flattening
Engine tests refactoring
Tests: don’t pass ‘values’ to task constructor
Test fetching backends via entry points
Pin testtools to 0.9.34 in test requirements
Ensure we register the new zookeeper backend as an entrypoint
Implement ZooKeeper as persistence storage backend
Use addCleanup instead of tearDown in test_sql_persistence
Retain the same api for all helpers
Update execute/revert comments
Added more unit tests for Task and FunctorTask
Doc strings and comments clean-up
List examples function doesn’t accept arguments
Tests: Persistence test mixin fix
Test using mysql + postgres if available
Clean-up and improve async-utils tests
Use already defined PENDING variable
Add utilities for working with binary data
Cleanup engine base class
Engine cleanups
Update atom comments
Put full set of requirements to py26, py27 and py33 envs
Add base class Atom for all flow units
Add more requirements to cover tox environment
Put SQLAlchemy requirements on single line
Proper exception raised from check_task_transition
Fix function name typo in persistence utils
Use the same way of assert isinstance in all tests
Minor cleanup in test_examples
Add possibility to create Failure from exception
Exceptions cleanup
Alter is_locked() helper comment
Add a setup.cfg keywords to describe taskflow
Use the released toxgen tool instead of our copy
0.1.2¶
Move autobinding to task base class
Assert functor task revert/execute are callable
Use the six callback checker
Add envs for different sqlalchemy versions
Refactor task handler binding
Move six to the right location
Use constants for the execution event strings
Added htmlcov folder to .gitignore
Reduce visibility of task_action
Change internal data store of LogBook from list to dict
Misc minor fixes to taskflow/examples
Add connection_proxy param
Ignore doc build files
Fix spelling errors
Switch to just using tox
Enable H202 warning for flake8
Check tasks should not provide same values
Allow max_backoff and use count instead of attempts
Skip invariant checking and adding when nothing provided
Avoid not_done naming conflict
Add stronger checking of backend configuration
Raise type error instead of silencing it
Move the container fetcher function to utils
Explicitly list the valid transitions to RESUMING state
Name the graph property the same as in engine
Bind outside of the try block
Graph action refactoring
Add make_completed_future to async_utils
Update oslo-incubator copy to oslo-incubator commit 8b2b0b743
Ensure that mysql traditional mode is enabled
Move async utils to own file
Update requirements from opentack/requirements
Code cleanup for eventlet_utils.wait_fo_any
Refactor engine internals
Add wait_for_any method to eventlet utils
Introduce TaskExecutor
Run some engine tests with eventlet if it’s available
Do not create TaskAction for each task
Storage: use names instead of uuids in interface
Add tests for metadata updates
Fix sqlalchemy 0.8 issues
Fix minor python3 incompatibility
Speed up FlowDetail.find
Fix misspellings
Raise exception when trying to run empty flow
Use update_task_metadata in set_task_progress
Capture task duration
Fix another instance of callback comparison
Don’t forget to return self
Fixes how instances methods are not deregistered
Targeted graph flow pattern
All classes should explicitly inherit object class
Initial commit of sphinx related files
Improve is_valid_attribute_name utility function
Coverage calculation improvements
Fix up python 3.3 incompatabilities
0.1.1¶
Pass flow failures to task’s revert method
Storage: add methods to get all flow failures
Pbr requirement went missing
Update code to comply with hacking 0.8.0
Don’t reset tasks to PENDING state while reverting
Let pbr determine version automatically
Be more careful when passing result to revert()
0.1¶
Support for optional task arguments
Do not erase task progress details
Storage: restore injected data on resumption
Inherit the greenpool default size
Add debug logging showing what is flattened
Remove incorrect comment
Unit tests refactoring
Use py3kcompat.urlutils from oslo instead of six.urllib_parse
Update oslo and bring py3kcompat in
Support several output formats in state_graph tool
Remove task_action state checks
Wrapped exception doc/intro comment updates
Doc/intro updates for simple_linear_listening
Add docs/intro to simple_linear example
Update intro/comments for reverting_linear example
Add docs explaining what/how resume_volume_create works
A few resuming from backend comment adjustments
Add an introduction to explain resume_many example
Increase persistence example comments
Boost graph flow example comments
Also allow “_” to be valid identifier
Remove uuid from taskflow.flow.Flow
A few additional example boot_vm comments + tweaks
Add a resuming booting vm example
Add task state verification
Beef up storage comments
Removed unused utilities
Helpers to save flow factory in metadata
Storage: add flow name and uuid properties
Create logbook if not provided for create_flow_details
Prepare for 0.1 release
Comment additions for exponential backoff
Beef up the action engine comments
Pattern comment additions/adjustments
Add more comments to flow/task
Save with the same connection
Add a persistence util logbook formatting function
Rename get_graph() -> execution_graph
Continue adding docs to examples
Add more comments that explain example & usage
Add more comments that explain example & usage
Add more comments that explain example & usage
Add more comments that explain example & usage
Fix several python3 incompatibilities
Python3 compatibility for utils.reflection
No module name for builtin type and exception names
Fix python3 compatibility issues in examples
Fix print statements for python 2/3
Add a mini-cinder volume create with resumption
Update oslo copy and bring over versionutils
Move toward python 3/2 compatible metaclass
Add a secondary booting vm example
Resumption from backend for action engine
A few wording/spelling adjustments
Create a green executor & green future
Add a simple mini-billing stack example
Add a example which uses a sqlite persistence layer
Add state to dot->svg tool
Add a set of useful listeners
Remove decorators and move to utils
Add reasons as to why the edges were created
Fix entrypoints being updated/created by update.py
Validate each flow state change
Update state sequence for failed flows
Flow utils and adding comments
Bump requirements to the latest
Add a inspect sanity check and note about bound methods
Some small exception cleanups
Check for duplicate task names on flattening
Correctly save task versions
Allow access by index
Fix importing of module files
Wrapping and serializing failures
Simpler API to load flows into engines
Avoid setting object variables
A few adjustments to the progress code
Cleanup unused states
Remove d2to dependency
Warn if multiple providers found
Memory persistence backend improvements
Create database from models for SQLite
Don’t allow mutating operations on the underlying graph
Add graph density
Suspend single and multi threaded engines
Remove old tests for unexisted flow types
Boot fake vm example fixed
Export graph to dot util
Remove unused utility classes
Remove black list of graph flow
Task decorator was removed and examples updated
Remove weakref usage
Add basic sanity tests for unordered flow
Clean up job/jobboard code
Add a directory/filesystem based persistence layer
Remove the older (not used) resumption mechanism
Reintegrate parallel action
Add a flow flattening util
Allow to specify default provides at task definition
Graph flow, sequential graph action
Task progress
Verify provides and requires
Remap the emails of the committers
Use executors instead of pools
Fix linked exception forming
Remove threaded and distributed flows
Add check that task provides all results it should
Use six string types instead of basestring
Remove usage of oslo.db and oslo.config
Move toward using a backend+connection model
Add provides and requires properties to Flow
Fixed crash when running the engine
Remove the common config since its not needed
Allow the lock decorator to take a list
Allow provides to be a set and results to be a dictionary
Allow engines to be copied + blacklist broken flows
Add link to why we have to make this factory due to late binding
Use the lock decorator and close/join the thread pool
Engine, task, linear_flow unification
Combine multiple exceptions into a linked one
Converted some examples to use patterns/engines
MultiThreaded engine and parallel action
State management for engines
Action engine: save task results
Initial implementation of action-based engine
Further updates to update.py
Split utils module
Rename Task.__call__ to Task.execute
Reader/writer no longer used
Rename “revert_with” => “revert” and “execute_with” to “execute”
Notify on task reversion
Have runner keep the exception
Use distutil version classes
Add features to task.Task
Add get_required_callable_args utility function
Add get_callable_name utility function
Require uuid + move functor_task to task.py
Check examples when running tests
Use the same root test class
LazyPluggable is no longer used
Add a locally running threaded flow
Change namings in functor_task and add docs to its __init__
Rework the persistence layer
Do not have the runner modify the uuid
Refactor decorators
Nicer way to make task out of any callable
Use oslo’s sqlalchemy layer
File movements
Added Backend API Database Implementation
Added Memory Persistence API and Generic Datatypes
Resync the latest oslo code
Remove openstack.common.exception usage
Forgot to move this one to the right folder
Add a new simple calculator example
Quiet the provider linking
Deep-copy not always possible
Add a example which simulates booting a vm
Add a more complicated graph example
Move examples under the source tree
Adjust a bunch of hacking violations
Fix typos in test_linear_flow.py and simple_linear_listening.py
Fix minor code style
Fix two minor bugs in docs/examples
Show file modifications and fix dirpath based on config file
Add a way to use taskflow until library stabilized
Provide the length of the flows
Parents should be frozen after creation
Allow graph dependencies to be manually provided
Add helper reset internals function
Move to using pbr
Unify creation/usage of uuids
Use the runner interface as the best task lookup
Ensure we document and complete correct removal
Pass runners instead of task objects/uuids
Move how resuming is done to be disconnected from jobs/flows
Clear out before connecting
Make connection/validation of tasks be after they are added
Add helper to do notification
Store results by add() uuid instead of in array format
Integrate better locking and a runner helper class
Cleaning up various components
Move some of the ordered flow helper classes to utils
Allow instance methods to be wrapped and unwrapped correctly
Add a start of a few simple examples
Update readme to point to links
Fix most of the hacking rules
Fix all flake8 E* and F* errors
Fix the current flake8 errors
Don’t keep the state/version in the task name
Dinky change to trigger jenkins so I can cleanup
Add the task to the accumulator before running
Add .settings and .venv into .gitignore
Fix tests for python 2.6
Add the ability to soft_reset a workflow
Add a .gitreview file so that git-review works
Ensure we have an exception and capture the exc_info
Update how graph results are fetched when they are optional
Allow for optional task requirements
We were not notifying when errors occured so fix that
Bring over the nova get_wrapped_function helper and use it
Allow for passing in the metadata when creating a task detail entry
Update how the version task functor attribute is found
Remove more tabs incidents
Removed test noise and formatted for pep8
Continue work on decorator usage
Ensure we pickup the packages
Fixed pep8 formatting… Finally
Add flow disassociation and adjust the assocate path
Add a setup.cfg and populate it with a default set of nosetests options
Fix spacing
Add a better task name algorithm
Add a major/minor version
Add a get many attr/s and join helper functions
Reduce test noise
Fix a few unit tests due to changes
Ensure we handle functor names and resetting correctly
Remove safe_attr
Modifying db tests
Removing .pyc
Fixing .py in .gitignore
Update db api test
DB api test cases and revisions
Allow for turning off auto-extract and add a test
Use a function to filter args and add comments
Use update instead of overwrite
Move decorators to new file and update to use better wraps()
Continue work with decorator usage
Update with adding a provides and requires decorator for standalone function usage
Instead of apply use __call__
Add comment to why we accumulate before notifying task listeners
Use a default sqlite backing using a taskflow file
Add a basic rollback accumlator test
Use rollback accumulator and remove requires()/provides() from being functions
Allow (or disallow) multiple providers of items
Clean the lines in a seperate function
Resync with oslo-incubator
Remove uuid since we are now using uuidutils
Remove error code not found in strict version of pylint
Include more dev testing packages + matching versions
Update dependencies for new db/distributed backends
Move some of the functions to use there openstack/common counterparts
More import fixups
Patch up the imports
Fix syntax error
Rename cause -> exception and make exception optional
Allow any of the previous tasks to satisfy requirements
Ensure we change the self and parents states correctly
Always have a name provided
Cleaning up files/extraneous files/fixing relations
More pylint cleanups
Make more tests for linear and shuffle test utils to common file
Only do differences on set objects
Ensure we fetch the appropriate inputs for the running task
Have the linear workflow verify the tasks inputs
Specify that task provides/requires must be an immutable set
Clean Up for DB changes
db api defined
Fleshing out sqlalchemy api
Almost done with sqlalchemy api
Fix state check
Fix flow exception wording
Ensure job is pending before we associate and run
More pylint cleanups
Ensure we associate with parent flows as well
Add a nice run() method to the job class that will run a flow
Massive pylint cleanup
deleting .swp files
deleting .swp files
cleaning for initial pull request
Add a few more graph ordering test cases
Update automatic naming and arg checks
Update order calls and connect call
Move flow failure to flow file and correctly catch ordering failure
Just kidding - really fixing relations this time
Fixing table relations
Allow job id to be passed in
Check who is being connected to and ensure > 0 connectors
Move the await function to utils
Graph tests and adjustments releated to
Add graph flow tests
Fix name changes missed
Enable extraction of what a functor requires from its args
Called flow now, not workflow
Second pass at models
More tests
Simplify existence checks
More pythonic functions and workflow -> flow renaming
Added more utils, added model for workflow
Spelling errors and stuff
adding parentheses to read method
Implemented basic sqlalchemy session class
Setting up Configs and SQLAlchemy/DB backend
Fix the import
Use a different logger method if tolerant vs not tolerant
More function comments
Add a bunch of linear workflow tests
Allow resuming stage to be interrupted
Fix the missing context variable
Moving over celery/distributed workflows
Update description wording
Pep fix
Instead of using notify member functions, just use functors
More wording fixes
Add the ability to alter the task failure reconcilation
Correctly run the tasks after partial resumption
Another wording fix
Spelling fix
Allow the functor task to take a name and provide it a default
Updated functor task comments
Move some of the useful helpers and functions to other files
Add the ability to associate a workflow with a job
Move the useful functor wrapping task from test to wrappers file
Add a thread posting/claiming example and rework tests to use it
After adding reposting/unclaiming reflect those changes here
Add a nicer string name that shows what the class name is
Adjust some of the states jobs and workflows could be in
Add a more useful name that shows this is a task
Remove impl of erasing which doesn’t do much and allow for job reposting
Various reworkings
Rename logbook contents
Get a memory test example working
Add a pylintrc file to be used with pylint
Rework the logbook to be chapter/page based
Move ordered workflow to its own file
Increase the number of comments
Start adding in a more generic DAG based workflow
Remove dict_provider dependency
Rework due to code comments
Begin adding testing functionality
Fill in the majority of the memory job
Rework how we should be using lists instead of ordereddicts for optimal usage
Add a context manager to the useful read/writer lock
Ensure that the task has a name
Add a running state which can be used to know when a workflow is running
Rename the date created field
Add some search functionality and adjust the await() function params
Remove and add a few new exceptions
Shrink down the exposed methods
Remove the promise object for now
Add RESUMING
Fix spelling
Continue on getting ready for the memory impl. to be useful
On python <= 2.6 we need to import ordereddict
Remove a few other references to nova
Add in openstack common and remove patch references
Move simplification over
Continue moving here
Update README.md
Update readme
Move the code over for now
Initial commit
