Merge "Fixing notify message of manage_existing flow"
This commit is contained in:
commit
17f2d9c390
@ -114,7 +114,8 @@ def get_flow(context, db, driver, host, volume_id, ref):
|
|||||||
create_api.QuotaReserveTask(),
|
create_api.QuotaReserveTask(),
|
||||||
ManageExistingTask(db, driver),
|
ManageExistingTask(db, driver),
|
||||||
create_api.QuotaCommitTask(),
|
create_api.QuotaCommitTask(),
|
||||||
create_mgr.CreateVolumeOnFinishTask(db, "create.end"))
|
create_mgr.CreateVolumeOnFinishTask(db,
|
||||||
|
"manage_existing.end"))
|
||||||
|
|
||||||
# Now load (but do not run) the flow using the provided initial data.
|
# Now load (but do not run) the flow using the provided initial data.
|
||||||
return taskflow.engines.load(volume_flow, store=create_what)
|
return taskflow.engines.load(volume_flow, store=create_what)
|
||||||
|
Loading…
Reference in New Issue
Block a user