diff --git a/octavia/controller/worker/v1/flows/amphora_flows.py b/octavia/controller/worker/v1/flows/amphora_flows.py index 22514ddeae..be041a8071 100644 --- a/octavia/controller/worker/v1/flows/amphora_flows.py +++ b/octavia/controller/worker/v1/flows/amphora_flows.py @@ -364,6 +364,10 @@ class AmphoraFlows(object): rebind={constants.AMPHORA: constants.FAILED_AMPHORA}, requires=constants.AMPHORA)) + failover_amphora_flow.add(network_tasks.FailoverPreparationForAmphora( + rebind={constants.AMPHORA: constants.FAILED_AMPHORA}, + requires=constants.AMPHORA)) + # Note: It seems intuitive to boot an amphora prior to deleting # the old amphora, however this is a complicated issue. # If the target host (due to anit-affinity) is resource diff --git a/octavia/controller/worker/v2/flows/amphora_flows.py b/octavia/controller/worker/v2/flows/amphora_flows.py index 09deab886e..5693125f75 100644 --- a/octavia/controller/worker/v2/flows/amphora_flows.py +++ b/octavia/controller/worker/v2/flows/amphora_flows.py @@ -364,6 +364,10 @@ class AmphoraFlows(object): rebind={constants.AMPHORA: constants.FAILED_AMPHORA}, requires=constants.AMPHORA)) + failover_amphora_flow.add(network_tasks.FailoverPreparationForAmphora( + rebind={constants.AMPHORA: constants.FAILED_AMPHORA}, + requires=constants.AMPHORA)) + # Note: It seems intuitive to boot an amphora prior to deleting # the old amphora, however this is a complicated issue. # If the target host (due to anit-affinity) is resource