Skip to content

Commit

Permalink
Logging tweaks
Browse files Browse the repository at this point in the history
  • Loading branch information
rtitle committed Sep 11, 2017
1 parent 4ecc35e commit 168f2a7
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ class ClusterDnsCache(proxyConfig: ProxyConfig, dbRef: DbReference) extends Acto
(c.googleProject, c.clusterName) -> ClusterNotReady
}.toMap

logger.info(s"Saved ${clusters.size} clusters to DNS cache, ${clustersWithIp.size} with IPs")
logger.debug(s"Saved ${clusters.size} clusters to DNS cache, ${clustersWithIp.size} with IPs")
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -27,11 +27,11 @@ class ClusterMonitorSupervisor(monitorConfig: MonitorConfig, gdDAO: DataprocDAO,

override def receive: Receive = {
case ClusterCreated(cluster) =>
logger.info(s"Monitoring cluster ${cluster.googleProject}/${cluster.clusterName} for initialization")
logger.info(s"Monitoring cluster ${cluster.googleProject}/${cluster.clusterName} for initialization.")
startClusterMonitorActor(cluster)

case ClusterDeleted(cluster, recreate) =>
logger.info(s"Monitoring cluster ${cluster.googleProject}/${cluster.clusterName} for deletion")
logger.info(s"Monitoring cluster ${cluster.googleProject}/${cluster.clusterName} for deletion.")
startClusterMonitorActor(cluster, recreate)

case RecreateCluster(cluster) =>
Expand Down

0 comments on commit 168f2a7

Please sign in to comment.