[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

doc/sphinx_util.py

@@ -1,5 +1,6 @@
 # -*- coding: utf-8 -*-
 """Helper utilty function for customization."""
+
 import os
 import subprocess
 import sys

tracker/dmlc_tracker/kubernetes.py

@@ -4,6 +4,7 @@
 
 One need to make sure kubectl-able.
 """
+
 from __future__ import absolute_import
 
 import yaml

tracker/dmlc_tracker/launcher.py

@@ -1,6 +1,7 @@
 #!/usr/bin/env python3
 # pylint: disable=invalid-name
 """The container launcher script that launches DMLC with the right env variable."""
+
 from __future__ import absolute_import
 
 import glob
@@ -55,7 +56,7 @@ def main():
     if hadoop_home:
         library_path.append("%s/lib/native" % hdfs_home)
         library_path.append("%s/lib" % hdfs_home)
-        (classpath, _) = subprocess.Popen(
+        classpath, _ = subprocess.Popen(
             "%s/bin/hadoop classpath" % hadoop_home,
             stdout=subprocess.PIPE,
             shell=True,

tracker/dmlc_tracker/mesos.py

@@ -4,6 +4,7 @@
 
 One need to make sure all slaves machines are ssh-able.
 """
+
 from __future__ import absolute_import
 
 import json

tracker/dmlc_tracker/mpi.py

@@ -26,7 +26,7 @@ def get_mpi_env(envs):
         return cmd
 
     # decide MPI version.
-    (out, err) = subprocess.Popen(
+    out, err = subprocess.Popen(
         ["mpirun", "--version"], stdout=subprocess.PIPE, stderr=subprocess.PIPE
     ).communicate()
     if b"Open MPI" in out:

tracker/dmlc_tracker/opts.py

@@ -1,5 +1,6 @@
 # pylint: disable=invalid-name
 """Command line options of job submission script."""
+
 import argparse
 import os
 
@@ -317,7 +318,7 @@ def get_opts(args=None):
         type=int,
         help=("Number of attempt local tracker can restart slave."),
     )
-    (args, unknown) = parser.parse_known_args(args)
+    args, unknown = parser.parse_known_args(args)
     args.command += unknown
 
     if args.cluster is None:

tracker/dmlc_tracker/ssh.py

@@ -4,6 +4,7 @@
 
 One need to make sure all slaves machines are ssh-able.
 """
+
 from __future__ import absolute_import
 
 import logging
@@ -98,7 +99,7 @@ def run(prog):
         # launch jobs
         for i in range(nworker + nserver):
             pass_envs["DMLC_ROLE"] = "server" if i < nserver else "worker"
-            (node, port) = hosts[i % len(hosts)]
+            node, port = hosts[i % len(hosts)]
             pass_envs["DMLC_NODE_HOST"] = node
             prog = (
                 get_env(pass_envs)

tracker/dmlc_tracker/yarn.py

@@ -55,13 +55,13 @@ def yarn_submit(args, nworker, nserver, pass_env):
         ), "failed to build dmlc-yarn.jar, try it manually"
 
     # detech hadoop version
-    (out, _) = subprocess.Popen(
+    out, _ = subprocess.Popen(
         "%s version" % hadoop_binary, shell=True, stdout=subprocess.PIPE
     ).communicate()
     out = py_str(out).split("\n")[0].split()
     assert out[0] == "Hadoop", "cannot parse hadoop version string"
     hadoop_version = int(out[1].split(".")[0])
-    (classpath, _) = subprocess.Popen(
+    classpath, _ = subprocess.Popen(
         "%s classpath" % hadoop_binary, shell=True, stdout=subprocess.PIPE
     ).communicate()
     classpath = py_str(classpath).strip()