fill overlong lines

aexecutor/process.py

@@ -272,7 +272,8 @@ class ProcessPoolExecutor(_base.Executor):
         """
         def shutdown_worker():
             # This is an upper bound
-            nb_children_alive = sum(p.is_alive() for p in self._processes.values())
+            nb_children_alive = sum(p.is_alive()
+                                    for p in self._processes.values())
             for i in range(0, nb_children_alive):
                 self._call_queue.put_nowait(None)
             # Release the queue's resources as soon as possible.
@@ -303,7 +304,8 @@ class ProcessPoolExecutor(_base.Executor):
             result_item = reader.recv()
             self._reader_event.clear()
             if result_item is not None:
-                work_item = self._pending_work_items.pop(result_item.work_id, None)
+                work_item = self._pending_work_items.pop(result_item.work_id,
+                                                         None)
                 # work_item can be None if another process terminated (see above)
                 if work_item is not None:
                     if not work_item.future.cancelled():
@@ -313,18 +315,19 @@ class ProcessPoolExecutor(_base.Executor):
                             work_item.future.set_result(result_item.result)
                     # Delete references to object. See issue16284
                     del work_item
-            # No more work items can be added if the executor that owns this worker
-            # has been shutdown.
+            # No more work items can be added if the executor that owns this
+            # worker has been shutdown.
             if self._shutdown_thread:
                 try:
-                    # Since no new work items can be added, it is safe to shutdown
-                    # this thread if there are no pending work items.
+                    # Since no new work items can be added, it is safe to
+                    # shutdown this thread if there are no pending work items.
                     if not self._pending_work_items:
                         shutdown_worker()
                         return
                 except Full:
                     # This is not a problem: we will eventually be woken up (in
-                    # self._result_queue.get()) and be able to send a sentinel again.
+                    # self._result_queue.get()) and be able to send a sentinel
+                    # again.
                     pass
 
     def _start_queue_management_thread(self):