diff --git a/monkey/infection_monkey/exploit/sshexec.py b/monkey/infection_monkey/exploit/sshexec.py
index 8fa5f9ad4..c8ea2f415 100644
--- a/monkey/infection_monkey/exploit/sshexec.py
+++ b/monkey/infection_monkey/exploit/sshexec.py
@@ -188,6 +188,39 @@ class SSHExploiter(HostExploiter):
             self._set_interrupted()
             return self.exploit_result
 
+        return self._propagate(ssh)
+
+    def _exploit(self) -> paramiko.SSHClient:
+        port = SSH_PORT
+
+        # if ssh banner found on different port, use that port.
+        for servkey, servdata in list(self.host.services.items()):
+            if servdata.get("name") == "ssh" and servkey.startswith("tcp-"):
+                port = int(servkey.replace("tcp-", ""))
+
+        is_open, _ = check_tcp_port(self.host.ip_addr, port)
+        if not is_open:
+            self.exploit_result.error_message = f"SSH port is closed on {self.host}, skipping"
+            self._publish_exploitation_event(
+                target=self.host.ip_addr,
+                exploitation_success=False,
+                error_message=self.exploit_result.error_message,
+                tags=(SSH_EXPLOITER_TAG,),
+            )
+            logger.info(self.exploit_result.error_message)
+            raise FailedExploitationError(self.exploit_result.error_message)
+
+        try:
+            ssh = self.exploit_with_ssh_keys(port)
+        except FailedExploitationError:
+            try:
+                ssh = self.exploit_with_login_creds(port)
+            except FailedExploitationError:
+                raise FailedExploitationError("Exploiter SSHExploiter is giving up...")
+
+        return ssh
+
+    def _propagate(self, ssh: paramiko.SSHClient):
         if not self.host.os.get("type") and not self._get_victim_os(ssh):
             return self.exploit_result
 
@@ -276,36 +309,6 @@ class SSHExploiter(HostExploiter):
             logger.error(self.exploit_result.error_message)
             return self.exploit_result
 
-    def _exploit(self) -> paramiko.SSHClient:
-        port = SSH_PORT
-
-        # if ssh banner found on different port, use that port.
-        for servkey, servdata in list(self.host.services.items()):
-            if servdata.get("name") == "ssh" and servkey.startswith("tcp-"):
-                port = int(servkey.replace("tcp-", ""))
-
-        is_open, _ = check_tcp_port(self.host.ip_addr, port)
-        if not is_open:
-            self.exploit_result.error_message = f"SSH port is closed on {self.host}, skipping"
-            self._publish_exploitation_event(
-                target=self.host.ip_addr,
-                exploitation_success=False,
-                error_message=self.exploit_result.error_message,
-                tags=(SSH_EXPLOITER_TAG,),
-            )
-            logger.info(self.exploit_result.error_message)
-            raise FailedExploitationError(self.exploit_result.error_message)
-
-        try:
-            ssh = self.exploit_with_ssh_keys(port)
-        except FailedExploitationError:
-            try:
-                ssh = self.exploit_with_login_creds(port)
-            except FailedExploitationError:
-                raise FailedExploitationError("Exploiter SSHExploiter is giving up...")
-
-        return ssh
-
     def _get_victim_os(self, ssh: paramiko.SSHClient) -> bool:
         try:
             _, stdout, _ = ssh.exec_command("uname -o", timeout=SSH_EXEC_TIMEOUT)