Skip to content

Commit

Permalink
Fixing pylint with lines too long
Browse files Browse the repository at this point in the history
Signed-off-by: mattahrens <[email protected]>
  • Loading branch information
mattahrens committed Nov 3, 2023
1 parent a9ceef6 commit 644a2a3
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions user_tools/src/spark_rapids_pytools/cloud_api/onprem.py
Original file line number Diff line number Diff line change
Expand Up @@ -312,8 +312,10 @@ def _get_cost_per_cluster(self, cluster: ClusterGetAccessor):
if self.price_provider.name.casefold() == 'dataproc':
master_cost = self.__calculate_dataproc_group_cost(cluster, SparkNodeType.MASTER)
workers_cost = self.__calculate_dataproc_group_cost(cluster, SparkNodeType.WORKER)
master_cores = cluster.get_nodes_cnt(SparkNodeType.MASTER) * cluster.get_node_core_count(SparkNodeType.MASTER)
worker_cores = cluster.get_nodes_cnt(SparkNodeType.WORKER) * cluster.get_node_core_count(SparkNodeType.WORKER)
master_cores = cluster.get_nodes_cnt(SparkNodeType.MASTER) * \
cluster.get_node_core_count(SparkNodeType.MASTER)
worker_cores = cluster.get_nodes_cnt(SparkNodeType.WORKER) * \
cluster.get_node_core_count(SparkNodeType.WORKER)
dataproc_cost = self.price_provider.get_container_cost() * (master_cores + worker_cores)
total_cost = master_cost + workers_cost + dataproc_cost
return total_cost

0 comments on commit 644a2a3

Please sign in to comment.