diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/assignment/TrainedModelAssignmentNodeService.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/assignment/TrainedModelAssignmentNodeService.java
index 3fac7c387b12e..8d137fa6fab98 100644
--- a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/assignment/TrainedModelAssignmentNodeService.java
+++ b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/assignment/TrainedModelAssignmentNodeService.java
@@ -209,7 +209,9 @@ void loadQueuedModels() {
             try {
                 deploymentManager.startDeployment(loadingTask, listener);
                 // This needs to be synchronous here in the utility thread to keep queueing order
+                logger.info("before get deployed task");
                 TrainedModelDeploymentTask deployedTask = listener.actionGet();
+                logger.info("after get deployed task");
                 // kicks off asynchronous cluster state update
                 handleLoadSuccess(deployedTask);
             } catch (Exception ex) {
diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/deployment/DeploymentManager.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/deployment/DeploymentManager.java
index 18e89732daf21..8c541e040ee6c 100644
--- a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/deployment/DeploymentManager.java
+++ b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/deployment/DeploymentManager.java
@@ -156,9 +156,11 @@ public void startDeployment(TrainedModelDeploymentTask task, ActionListener<Trai
 
         ActionListener<TrainedModelDeploymentTask> failedDeploymentListener = ActionListener.wrap(finalListener::onResponse, failure -> {
             ProcessContext failedContext = processContextByAllocation.remove(task.getId());
+            logger.info("failedContext is " + failedContext);
             if (failedContext != null) {
                 failedContext.forcefullyStopProcess();
             }
+            logger.info("before final listener");
             finalListener.onFailure(failure);
         });
 
@@ -205,7 +207,9 @@ public void startDeployment(TrainedModelDeploymentTask task, ActionListener<Trai
 
                             @Override
                             public void onFailure(Exception e) {
+                                logger.info("before failedDeploymentListener.onFailure");
                                 failedDeploymentListener.onFailure(e);
+                                logger.info("after failedDeploymentListener.onFailure");
                             }
 
                             @Override
diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/pytorch/process/NativePyTorchProcessFactory.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/pytorch/process/NativePyTorchProcessFactory.java
index b26c6720ed179..e538a6c686881 100644
--- a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/pytorch/process/NativePyTorchProcessFactory.java
+++ b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/pytorch/process/NativePyTorchProcessFactory.java
@@ -89,7 +89,7 @@ public NativePyTorchProcess createProcess(
             process.start(executorService);
         } catch (IOException | EsRejectedExecutionException e) {
             String msg = "Failed to connect to pytorch process for job " + task.getDeploymentId();
-            logger.error(msg);
+            logger.error(msg, e);
             try {
                 IOUtils.close(process);
             } catch (IOException ioe) {