Merge pull request #835 from shtripat/expand-cluster-with-detected-pe…

…ers-1

Added event log for newly added nodes to the cluster

tendrl/commons/flows/expand_cluster_with_detected_peers/__init__.py

@@ -62,6 +62,7 @@ def run(self):
  "import" % integration_id)
 
  job_ids = []
+ new_peers = []
  for node_id in node_ids:
  _cnc = NS.tendrl.objects.ClusterNodeContext(
  node_id=node_id
@@ -99,10 +100,11 @@ def run(self):
  job_id=self.parameters['job_id']
  )
  job_ids.append(_job_id)
+ new_peers.append(node_id)
 
  loop_count = 0
  # Wait for (no of nodes) * 6 minutes for import to complete
- wait_count = len(node_ids) * 36
+ wait_count = len(job_ids) * 36
  while True:
  if loop_count >= wait_count:
  logger.log(
@@ -141,4 +143,16 @@ def run(self):
  'job_id': self.job_id
  }
  _cluster.save()
+
+ logger.log(
+ "info",
+ NS.publisher_id,
+ {
+ "message": "Newly detected node(s) added to the cluster."
+ "(nodes: %s) (integration_id: %s)" % (
+ str(new_peers),
+ integration_id
+ )
+ }
+ )
  return True