diff --git a/simplyblock_core/cluster_ops.py b/simplyblock_core/cluster_ops.py
index 337c2abe8..0311f0407 100644
--- a/simplyblock_core/cluster_ops.py
+++ b/simplyblock_core/cluster_ops.py
@@ -651,6 +651,14 @@ def cluster_activate(cl_id, force=False, force_lvstore_create=False) -> None:
                 if not ret:
                     logger.info("Failed to resume JC compression adding task...")
                     tasks_controller.add_jc_comp_resume_task(node.cluster_id, node.get_id(), jm_vuid=node.jm_vuid)
+                # start comp on node for sec stack
+                nodes = db_controller.get_primary_storage_nodes_by_secondary_node_id(node.get_id())
+                if nodes:
+                    sec_node = nodes[0]
+                    ret, err = node.rpc_client().jc_suspend_compression(jm_vuid=sec_node.jm_vuid, suspend=False)
+                    if not ret:
+                        logger.info("Failed to resume JC compression adding task...")
+                        tasks_controller.add_jc_comp_resume_task(node.cluster_id, node.get_id(), jm_vuid=sec_node.jm_vuid)
 
     if not cluster.cluster_max_size:
         cluster = db_controller.get_cluster_by_id(cl_id)
diff --git a/simplyblock_core/storage_node_ops.py b/simplyblock_core/storage_node_ops.py
index dbb16d42e..2c1c9a62c 100644
--- a/simplyblock_core/storage_node_ops.py
+++ b/simplyblock_core/storage_node_ops.py
@@ -3088,12 +3088,12 @@ def recreate_lvstore_on_sec(secondary_node):
             primary_node.write_to_db()
             return False
 
-        # sending to the node that is being restarted (secondary_node) with the secondary group jm_vuid (primary_node.jm_vuid)
-        ret, err = secondary_node.rpc_client().jc_suspend_compression(jm_vuid=primary_node.jm_vuid, suspend=False)
+        # sending to the node that is being restarted (secondary_node) with the secondary group jm_vuid (secondary_node.jm_vuid)
+        ret, err = secondary_node.rpc_client().jc_suspend_compression(jm_vuid=secondary_node.jm_vuid, suspend=False)
         if not ret:
             logger.info("Failed to resume JC compression adding task...")
             tasks_controller.add_jc_comp_resume_task(
-                secondary_node.cluster_id, secondary_node.get_id(), jm_vuid=primary_node.jm_vuid)
+                secondary_node.cluster_id, secondary_node.get_id(), jm_vuid=secondary_node.jm_vuid)
 
         ### 2- create lvols nvmf subsystems
         for lvol in lvol_list:
@@ -3625,12 +3625,6 @@ def create_lvstore(snode, ndcs, npcs, distr_bs, distr_chunk_bs, page_size_in_blo
             logger.error(err)
             return False
 
-        # sending to the other node (sec_node) with the primary group jm_vuid (snode.jm_vuid)
-        ret, err = sec_node.rpc_client().jc_suspend_compression(jm_vuid=snode.jm_vuid, suspend=False)
-        if not ret:
-            logger.info("Failed to resume JC compression adding task...")
-            tasks_controller.add_jc_comp_resume_task(sec_node.cluster_id, sec_node.get_id(), jm_vuid=snode.jm_vuid)
-
         sec_rpc_client = sec_node.rpc_client()
         sec_rpc_client.bdev_examine(snode.raid)
         sec_rpc_client.bdev_wait_for_examine()