Also note that if u use the following as a context manager this will be done for u.
https://github.com/openstack/taskflow/blob/master/taskflow/persistence/backends/__init__.py#L72
This would work as follows:
with backend.backend(conf) as backend: store = { ... } flow = get_my_flow() engine = engines.load(flow, engine_conf=engine_conf, store=store, backend=backend) engine.run() ....
Also note that if u use the following as a context manager this will be done for u.
https:/ /github. com/openstack/ taskflow/ blob/master/ taskflow/ persistence/ backends/ __init_ _.py#L72
This would work as follows:
with backend. backend( conf) as backend:
engine_ conf=engine_ conf,
store= store,
backend= backend)
store = { ... }
flow = get_my_flow()
engine = engines.load(flow,
engine.run()
....