diff --git a/gso/utils/workflow_steps.py b/gso/utils/workflow_steps.py
index a595bbc00b0176fcdbec51d29749d54d412f2f1d..fb166950d5cf821390b34dd04b0264deb3a54acb 100644
--- a/gso/utils/workflow_steps.py
+++ b/gso/utils/workflow_steps.py
@@ -1,7 +1,6 @@
 """Workflow steps that are shared across multiple workflows."""
 
 import json
-from operator import inv
 from typing import Any
 
 from orchestrator import inputstep, step
diff --git a/gso/workflows/router/promote_p_to_pe.py b/gso/workflows/router/promote_p_to_pe.py
index cdd6c9dbf809025992a19302a5d53b7aae0e1e72..101e4c65c5cddc0ecd8695ce2de4809362775177 100644
--- a/gso/workflows/router/promote_p_to_pe.py
+++ b/gso/workflows/router/promote_p_to_pe.py
@@ -200,7 +200,6 @@ def remove_p_from_pe_real(subscription: dict[str, Any], tt_number: str, process_
     }
 
 
-
 @step("[DRY RUN] Deploy routing instances")
 def deploy_routing_instances_dry(subscription: dict[str, Any], tt_number: str, process_id: UUIDstr) -> LSOState:
     """Perform a dry run of deploying routing instances."""
@@ -260,27 +259,6 @@ def update_subscription_model(subscription: Router) -> State:
     return {"subscription": subscription}
 
 
-@step("[DRY RUN] Add all P to this new PE")
-def add_all_p_to_pe_dry(subscription: dict[str, Any], tt_number: str, process_id: UUIDstr) -> LSOState:
-    """Perform a dry run of adding all P routers to the PE router."""
-    extra_vars = {
-        "dry_run": True,
-        "subscription": subscription,
-        "commit_comment": f"GSO_PROCESS_ID: {process_id} - TT_NUMBER: {tt_number} - Add all P-routers to this new PE",
-        "verb": "add_all_p_to_pe",
-        "p_router_list": generate_inventory_for_active_routers(
-            RouterRole.P, exclude_routers=[subscription["router"]["router_fqdn"]]
-        )["all"]["hosts"],
-    }
-
-    return {
-        "playbook_name": "update_ibgp_mesh.yaml",
-        "inventory": {"all": {"hosts": {subscription["router"]["router_fqdn"]: None}}},
-        "extra_vars": extra_vars,
-    }
-
-
-
 @step("[DRY RUN] Delete default routes")
 def delete_default_routes_dry(subscription: dict[str, Any], tt_number: str, process_id: UUIDstr) -> LSOState:
     """Perform a dry run of deleting the default routes."""