Remove pylint disable rule in CSPs

Signed-off-by: Partho Sarthi <[email protected]>
NVIDIA · Dec 17, 2024 · 1ea8147 · 1ea8147
1 parent 9b8111a
commit 1ea8147
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 5 deletions.
diff --git a/user_tools/src/spark_rapids_pytools/cloud_api/databricks_aws.py b/user_tools/src/spark_rapids_pytools/cloud_api/databricks_aws.py
@@ -31,7 +31,6 @@
 from spark_rapids_pytools.pricing.price_provider import SavingsEstimator
 
 
-# pylint: disable=abstract-method
 @dataclass
 class DBAWSPlatform(EMRPlatform):
     """

diff --git a/user_tools/src/spark_rapids_pytools/cloud_api/databricks_azure.py b/user_tools/src/spark_rapids_pytools/cloud_api/databricks_azure.py
@@ -29,7 +29,6 @@
 from spark_rapids_pytools.pricing.price_provider import SavingsEstimator
 
 
-# pylint: disable=abstract-method
 @dataclass
 class DBAzurePlatform(PlatformBase):
     """
@@ -89,6 +88,9 @@ def create_saving_estimator(self,
     def create_local_submission_job(self, job_prop, ctxt) -> Any:
         return DBAzureLocalRapidsJob(prop_container=job_prop, exec_ctxt=ctxt)
 
+    def create_distributed_submission_job(self, job_prop, ctxt) -> Any:
+        pass
+
     def validate_job_submission_args(self, submission_args: dict) -> dict:
         pass
 

diff --git a/user_tools/src/spark_rapids_pytools/cloud_api/dataproc.py b/user_tools/src/spark_rapids_pytools/cloud_api/dataproc.py
@@ -32,7 +32,6 @@
 from spark_rapids_pytools.pricing.price_provider import SavingsEstimator
 
 
-# pylint: disable=abstract-method
 @dataclass
 class DataprocPlatform(PlatformBase):
     """
@@ -131,6 +130,9 @@ def create_saving_estimator(self,
     def create_local_submission_job(self, job_prop, ctxt) -> Any:
         return DataprocLocalRapidsJob(prop_container=job_prop, exec_ctxt=ctxt)
 
+    def create_distributed_submission_job(self, job_prop, ctxt) -> Any:
+        pass
+
     def validate_job_submission_args(self, submission_args: dict) -> dict:
         pass
 

diff --git a/user_tools/src/spark_rapids_pytools/cloud_api/dataproc_gke.py b/user_tools/src/spark_rapids_pytools/cloud_api/dataproc_gke.py
@@ -29,7 +29,6 @@
 from spark_rapids_tools import CspEnv
 
 
-# pylint: disable=abstract-method
 @dataclass
 class DataprocGkePlatform(DataprocPlatform):
     """
@@ -93,6 +92,9 @@ def create_saving_estimator(self,
     def create_local_submission_job(self, job_prop, ctxt) -> Any:
         return DataprocGkeLocalRapidsJob(prop_container=job_prop, exec_ctxt=ctxt)
 
+    def create_distributed_submission_job(self, job_prop, ctxt) -> Any:
+        pass
+
 
 @dataclass
 class DataprocGkeCMDDriver(DataprocCMDDriver):

diff --git a/user_tools/src/spark_rapids_pytools/cloud_api/emr.py b/user_tools/src/spark_rapids_pytools/cloud_api/emr.py
@@ -31,7 +31,6 @@
 from spark_rapids_pytools.pricing.price_provider import SavingsEstimator
 
 
-# pylint: disable=abstract-method
 @dataclass
 class EMRPlatform(PlatformBase):
     """
@@ -116,6 +115,9 @@ def create_saving_estimator(self,
     def create_local_submission_job(self, job_prop, ctxt) -> Any:
         return EmrLocalRapidsJob(prop_container=job_prop, exec_ctxt=ctxt)
 
+    def create_distributed_submission_job(self, job_prop, ctxt) -> Any:
+        pass
+
     def generate_cluster_configuration(self, render_args: dict):
         image_version = self.configs.get_value_silent('clusterInference', 'defaultImage')
         render_args['IMAGE'] = f'"{image_version}"'