more f-string lint

Author: minrk

docs/source/conf.py

@@ -95,7 +95,7 @@
 from datetime import date
 
 project = 'ipyparallel'
-copyright = '%04d, The IPython Development Team' % date.today().year
+copyright = f'{date.today().year}, The IPython Development Team'
 author = 'The IPython Development Team'
 
 # The version info for the project you're documenting, acts as replacement for

docs/source/examples/customresults.py

@@ -30,7 +30,7 @@ def sleep_here(count, t):
     import sys
     import time
 
-    print("hi from engine %i" % id)
+    print(f"hi from engine {id}")
     sys.stdout.flush()
     time.sleep(t)
     return count, t
@@ -52,12 +52,12 @@ def sleep_here(count, t):
     for msg_id in finished:
         # we know these are done, so don't worry about blocking
         ar = rc.get_result(msg_id)
-        print("job id %s finished on engine %i" % (msg_id, ar.engine_id))
+        print(f"job id {msg_id} finished on engine {ar.engine_id}")
         print("with stdout:")
         print('    ' + ar.stdout.replace('\n', '\n    ').rstrip())
         print("and results:")
 
         # note that each job in a map always returns a list of length chunksize
         # even if chunksize == 1
         for count, t in ar.get():
-            print("  item %i: slept for %.2fs" % (count, t))
+            print(f"  item {count}: slept for {t:.2f}s")

docs/source/examples/daVinci Word Count/pwordfreq.py

@@ -68,18 +68,18 @@ def pwordfreq(view, fnames):
     block = nlines // n
     for i in range(n):
         chunk = lines[i * block : i * (block + 1)]
-        with open('davinci%i.txt' % i, 'w', encoding='utf8') as f:
+        with open(f'davinci{i}.txt', 'w', encoding='utf8') as f:
             f.write('\n'.join(chunk))
 
     try:  # python2
         cwd = os.path.abspath(os.getcwdu())
     except AttributeError:  # python3
         cwd = os.path.abspath(os.getcwd())
-    fnames = [os.path.join(cwd, 'davinci%i.txt' % i) for i in range(n)]
+    fnames = [os.path.join(cwd, f'davinci{i}.txt') for i in range(n)]
     tic = time.time()
     pfreqs = pwordfreq(view, fnames)
     toc = time.time()
     print_wordfreq(freqs)
-    print("Took %.3f s to calculate on %i engines" % (toc - tic, len(view.targets)))
+    print(f"Took {toc - tic:.3f}s to calculate on {len(view.targets)} engines")
     # cleanup split files
     map(os.remove, fnames)

docs/source/examples/dagdeps.py

@@ -100,7 +100,7 @@ def main(nodes, edges):
 
     client = parallel.Client()
     view = client.load_balanced_view()
-    print("submitting %i tasks with %i dependencies" % (nodes, edges))
+    print(f"submitting {nodes} tasks with {edges} dependencies")
     results = submit_jobs(view, G, jobs)
     print("waiting for results")
     client.wait_interactive()

docs/source/examples/interengine/communicator.py

@@ -21,8 +21,8 @@ def __init__(self, interface='tcp://*', identity=None):
         # bind to ports
         port = self.socket.bind_to_random_port(interface)
         pub_port = self.pub.bind_to_random_port(interface)
-        self.url = interface + ":%i" % port
-        self.pub_url = interface + ":%i" % pub_port
+        self.url = f"{interface}:{port}"
+        self.pub_url = f"{interface}:{pub_port}"
         # guess first public IP from socket
         self.location = socket.gethostbyname_ex(socket.gethostname())[-1][0]
         self.peers = {}

docs/source/examples/itermapresult.py

@@ -34,10 +34,10 @@
 # create a Reference to `id`. This will be a different value on each engine
 ref = ipp.Reference('id')
 print("sleeping for `id` seconds on each engine")
-tic = time.time()
+tic = time.perf_counter()
 ar = dv.apply(time.sleep, ref)
 for i, r in enumerate(ar):
-    print("%i: %.3f" % (i, time.time() - tic))
+    print(f"{i}: {time.perf_counter() - tic:.3f}")
 
 
 def sleep_here(t):
@@ -50,22 +50,22 @@ def sleep_here(t):
 # one call per task
 print("running with one call per task")
 amr = v.map(sleep_here, [0.01 * t for t in range(100)])
-tic = time.time()
+tic = time.perf_counter()
 for i, r in enumerate(amr):
-    print("task %i on engine %i: %.3f" % (i, r[0], time.time() - tic))
+    print(f"task {i} on engine {r[0]}: {time.perf_counter() - tic:.3f}")
 
 print("running with four calls per task")
 # with chunksize, we can have four calls per task
 amr = v.map(sleep_here, [0.01 * t for t in range(100)], chunksize=4)
-tic = time.time()
+tic = time.perf_counter()
 for i, r in enumerate(amr):
-    print("task %i on engine %i: %.3f" % (i, r[0], time.time() - tic))
+    print(f"task {i} on engine {r[0]}: {time.perf_counter() - tic:.3f}")
 
 print("running with two calls per task, with unordered results")
 # We can even iterate through faster results first, with ordered=False
 amr = v.map(
     sleep_here, [0.01 * t for t in range(100, 0, -1)], ordered=False, chunksize=2
 )
-tic = time.time()
+tic = time.perf_counter()
 for i, r in enumerate(amr):
-    print("slept %.2fs on engine %i: %.3f" % (r[1], r[0], time.time() - tic))
+    print(f"slept {r[1]:.2f}s on engine {r[0]}: {time.perf_counter() - tic:.3f}")

docs/source/examples/pi/parallelpi.py

@@ -29,8 +29,8 @@
 import ipyparallel as ipp
 
 # Files with digits of pi (10m digits each)
-filestring = 'pi200m.ascii.%(i)02dof20'
-files = [filestring % {'i': i} for i in range(1, 21)]
+filestring = 'pi200m.ascii.{}of20'
+files = [filestring.format(i) for i in range(1, 21)]
 
 # Connect to the IPython cluster
 c = ipp.Client()
@@ -42,7 +42,7 @@
 v = c[:]
 v.block = True
 # fetch the pi-files
-print("downloading %i files of pi" % n)
+print(f"downloading {n} files of pi")
 v.map(fetch_pi_file, files[:n])  # noqa: F821
 print("done")
 
@@ -60,10 +60,10 @@
 freqs150m = reduce_freqs(freqs_all)
 t2 = clock()
 digits_per_second8 = n * 10.0e6 / (t2 - t1)
-print("Digits per second (%i engines, %i0m digits): " % (n, n), digits_per_second8)
+print(f"Digits per second ({n} engines, {n}0m digits): ", digits_per_second8)
 
 print("Speedup: ", digits_per_second8 / digits_per_second1)
 
 plot_two_digit_freqs(freqs150m)
-plt.title("2 digit sequences in %i0m digits of pi" % n)
+plt.title(f"2 digit sequences in {n}0m digits of pi")
 plt.show()

docs/source/examples/task_profiler.py

@@ -60,10 +60,7 @@ def main():
     ]
     stime = sum(times)
 
-    print(
-        "executing %i tasks, totalling %.1f secs on %i engines"
-        % (opts.n, stime, nengines)
-    )
+    print(f"executing {opts.n} tasks, totalling {stime:.1f} secs on {nengines} engines")
     time.sleep(1)
     start = time.perf_counter()
     amr = view.map(time.sleep, times)
@@ -74,8 +71,8 @@ def main():
     scale = stime / ptime
 
     print(f"executed {stime:.1f} secs in {ptime:.1f} secs")
-    print("%.3fx parallel performance on %i engines" % (scale, nengines))
-    print("%.1f%% of theoretical max" % (100 * scale / nengines))
+    print(f"{scale:.3f}x parallel performance on {nengines} engines")
+    print(f"{scale / nengines:.1%} of theoretical max")
 
 
 if __name__ == '__main__':

docs/source/examples/wave2D/RectPartitioner.py

@@ -61,7 +61,7 @@ def prepare_communication(self):
 
         nsd_ = self.nsd
         if nsd_ < 1:
-            print('Number of space dimensions is %d, nothing to do' % nsd_)
+            print(f'Number of space dimensions is {nsd_}, nothing to do')
             return
 
         self.subd_rank = [-1, -1, -1]
@@ -93,7 +93,7 @@ def prepare_communication(self):
             self.subd_rank[1] = (my_id % offsets[2]) / self.num_parts[0]
             self.subd_rank[2] = my_id / offsets[2]
 
-        print("my_id=%d, subd_rank: " % my_id, self.subd_rank)
+        print(f"my_id={my_id}, subd_rank={self.subd_rank}")
         if my_id == 0:
             print("offsets=", offsets)
 

docs/source/examples/wave2D/communicator.py

@@ -27,8 +27,8 @@ def __init__(self, interface='tcp://*', identity=None):
         northport = self.north.bind_to_random_port(interface)
         eastport = self.east.bind_to_random_port(interface)
 
-        self.north_url = interface + ":%i" % northport
-        self.east_url = interface + ":%i" % eastport
+        self.north_url = f"{interface}:{northport}"
+        self.east_url = f"{interface}:{eastport}"
 
         # guess first public IP from socket
         self.location = socket.gethostbyname_ex(socket.gethostname())[-1][0]