Blacken Python files

Blacken Python files

example2/compute.py

@@ -3,12 +3,15 @@
 import argparse
 import time
 
-parser = argparse.ArgumentParser (description='compute for seconds')
-parser.add_argument ('integer', metavar='S', type=int,
-                     help='an integer for the number of seconds to compute')
+parser = argparse.ArgumentParser(description="compute for seconds")
+parser.add_argument(
+    "integer",
+    metavar="S",
+    type=int,
+    help="an integer for the number of seconds to compute",
+)
 
-args = parser.parse_args ()
-
-print "Will compute for " + str (args.integer) + " seconds."
-time.sleep (args.integer)
+args = parser.parse_args()
 
+print "Will compute for " + str(args.integer) + " seconds."
+time.sleep(args.integer)

example2/io-forwarding.py

@@ -3,12 +3,15 @@
 import argparse
 import time
 
-parser = argparse.ArgumentParser (description='forward I/O requests for seconds')
-parser.add_argument ('integer', metavar='S', type=int,
-                     help='an integer for the number of seconds to compute')
+parser = argparse.ArgumentParser(description="forward I/O requests for seconds")
+parser.add_argument(
+    "integer",
+    metavar="S",
+    type=int,
+    help="an integer for the number of seconds to compute",
+)
 
-args = parser.parse_args ()
-
-print "Will forward I/O requests for " + str (args.integer) + " seconds."
-time.sleep (args.integer)
+args = parser.parse_args()
 
+print "Will forward I/O requests for " + str(args.integer) + " seconds."
+time.sleep(args.integer)

example2/submitter.py

@@ -6,22 +6,18 @@
 import flux
 from flux.job import JobspecV1
 
-f = flux.Flux ()
+f = flux.Flux()
 
-compute_jobreq = JobspecV1.from_command (
-    command=["./compute.py", "120"],
-    num_tasks=4,
-    num_nodes=2,
-    cores_per_task=2)
-compute_jobreq.cwd = os.getcwd ()
-compute_jobreq.environment = dict (os.environ)
-print (flux.job.submit (f, compute_jobreq))
+compute_jobreq = JobspecV1.from_command(
+    command=["./compute.py", "120"], num_tasks=4, num_nodes=2, cores_per_task=2
+)
+compute_jobreq.cwd = os.getcwd()
+compute_jobreq.environment = dict(os.environ)
+print(flux.job.submit(f, compute_jobreq))
 
-io_jobreq = JobspecV1.from_command (
-    command=["./io-forwarding.py", "120"],
-    num_tasks=1,
-    num_nodes=1,
-    cores_per_task=1)
-io_jobreq.cwd = os.getcwd ()
-io_jobreq.environment = dict (os.environ)
-print (flux.job.submit (f, io_jobreq))
+io_jobreq = JobspecV1.from_command(
+    command=["./io-forwarding.py", "120"], num_tasks=1, num_nodes=1, cores_per_task=1
+)
+io_jobreq.cwd = os.getcwd()
+io_jobreq.environment = dict(os.environ)
+print(flux.job.submit(f, io_jobreq))

example2/submitter2.py

@@ -6,22 +6,18 @@
 import flux
 from flux.job import JobspecV1
 
-f = flux.Flux ()
+f = flux.Flux()
 
-compute_jobreq = JobspecV1.from_command (
-    command=["./compute.py", "120"],
-    num_tasks=6,
-    num_nodes=3,
-    cores_per_task=2)
-compute_jobreq.cwd = os.getcwd ()
-compute_jobreq.environment = dict (os.environ)
-print (flux.job.submit (f, compute_jobreq))
+compute_jobreq = JobspecV1.from_command(
+    command=["./compute.py", "120"], num_tasks=6, num_nodes=3, cores_per_task=2
+)
+compute_jobreq.cwd = os.getcwd()
+compute_jobreq.environment = dict(os.environ)
+print(flux.job.submit(f, compute_jobreq))
 
-io_jobreq = JobspecV1.from_command (
-    command=["./io-forwarding.py", "120"],
-    num_tasks=3,
-    num_nodes=3,
-    cores_per_task=1)
-io_jobreq.cwd = os.getcwd ()
-io_jobreq.environment = dict (os.environ)
-print (flux.job.submit (f, io_jobreq))
+io_jobreq = JobspecV1.from_command(
+    command=["./io-forwarding.py", "120"], num_tasks=3, num_nodes=3, cores_per_task=1
+)
+io_jobreq.cwd = os.getcwd()
+io_jobreq.environment = dict(os.environ)
+print(flux.job.submit(f, io_jobreq))