It should be relatively easy to plug-in a retry loop around/in https://github.com/openstack/taskflow/blob/master/taskflow/persistence/backends/impl_sqlalchemy.py#L299 (catching the appropriate exceptions and attempting the functor again...)
It should be relatively easy to plug-in a retry loop around/in https:/ /github. com/openstack/ taskflow/ blob/master/ taskflow/ persistence/ backends/ impl_sqlalchemy .py#L299 (catching the appropriate exceptions and attempting the functor again...)