Skip to content

Commit

Permalink
Fix pylint
Browse files Browse the repository at this point in the history
Signed-off-by: Partho Sarthi <psarthi@nvidia.com>
  • Loading branch information
parthosa committed Jan 29, 2025
1 parent 5713417 commit 4431d2e
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ def _construct_jar_cmd(self, file_path: str, executor_output_path: str) -> List[
classpath = ':'.join([
SparkFiles.get(os.path.basename(self.jar_cmd_args.tools_jar_path)),
self.jar_cmd_args.hadoop_classpath,
f'{self.get_env_var("SPARK_HOME")}/jars/*'
f"{self.get_env_var('SPARK_HOME')}/jars/*"
])

# Set the JVM log file path
Expand All @@ -84,7 +84,7 @@ def _construct_jar_cmd(self, file_path: str, executor_output_path: str) -> List[
# Construct the JAR command
return [
# pylint: disable=line-too-long
f'{self.get_env_var("JAVA_HOME")}/bin/java', # Java executable path
f"{self.get_env_var('JAVA_HOME')}/bin/java", # Java executable path
*self.jar_cmd_args.jvm_args, # JVM Arguments: Log configuration, memory settings, etc.
'-cp', classpath, # Classpath for dependencies
self.jar_cmd_args.jar_main_class, # Spark RAPIDS Tools main class
Expand Down Expand Up @@ -149,7 +149,7 @@ def _generate_log_lines(file_path: str, executor_output_path: str, jar_command:
f'Host: {socket.gethostname()}',
f'Event Log Path: {file_path}',
f'Executor Output Path: {executor_output_path}',
f'Command: {" ".join(jar_command)}',
f"Command: {' '.join(jar_command)}",
f'Processing Time: {processing_time}',
f'Status: {app_status.status.value}',
f'Error Description:\n {app_status.description}' if app_status.status == AppStatus.FAILURE else '',
Expand Down

0 comments on commit 4431d2e

Please sign in to comment.