From eeb67db861e3f3c30c04301cd8ceaea2bef33342 Mon Sep 17 00:00:00 2001
From: Daniel Edgecumbe <45787862+ls-daniel@users.noreply.github.com>
Date: Mon, 8 Jul 2019 21:22:26 +0100
Subject: [PATCH] [autoscaler] Log AWS NodeProvider create_instances (#4998)

* autoscaler: Log on AWS NodeProvider create_instances

* logging
---
 python/ray/autoscaler/aws/node_provider.py | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/python/ray/autoscaler/aws/node_provider.py b/python/ray/autoscaler/aws/node_provider.py
index 9d0bf4228..531f9bbe1 100644
--- a/python/ray/autoscaler/aws/node_provider.py
+++ b/python/ray/autoscaler/aws/node_provider.py
@@ -14,6 +14,9 @@ from ray.autoscaler.tags import TAG_RAY_CLUSTER_NAME, TAG_RAY_NODE_NAME
 from ray.ray_constants import BOTO_MAX_RETRIES
 from ray.autoscaler.log_timer import LogTimer
 
+import logging
+logger = logging.getLogger(__name__)
+
 
 def to_aws_format(tags):
     """Convert the Ray node name tag to the AWS-specific 'Name' tag."""
@@ -212,7 +215,15 @@ class AWSNodeProvider(NodeProvider):
             "SubnetId": subnet_id,
             "TagSpecifications": tag_specs
         })
-        self.ec2.create_instances(**conf)
+
+        logger.info(
+            "NodeProvider: Calling create_instances (count={}).".format(count))
+        L = self.ec2.create_instances(**conf)
+        for x in L:
+            logger.info("NodeProvider: Created instance "
+                        "[id={}, name={}, info={}]".format(
+                            x.instance_id, x.state["Name"],
+                            x.state_reason["Message"]))
 
     def terminate_node(self, node_id):
         node = self._get_cached_node(node_id)