From: Machinexa2 Date: Tue, 8 Jun 2021 09:47:15 +0000 (+0545) Subject: Use `from` imports (GH-26594) X-Git-Tag: v3.11.0a1~918 X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=d56e700d6c7ebf1a424260d0e4f0c291d1f5b3af;p=thirdparty%2FPython%2Fcpython.git Use `from` imports (GH-26594) from imports --- diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py index 764719859f7c..9904db78c5b4 100644 --- a/Lib/concurrent/futures/process.py +++ b/Lib/concurrent/futures/process.py @@ -56,7 +56,7 @@ import weakref from functools import partial import itertools import sys -import traceback +from traceback import format_exception _threads_wakeups = weakref.WeakKeyDictionary() @@ -123,8 +123,7 @@ class _RemoteTraceback(Exception): class _ExceptionWithTraceback: def __init__(self, exc, tb): - tb = traceback.format_exception(type(exc), exc, tb) - tb = ''.join(tb) + tb = ''.join(format_exception(type(exc), exc, tb)) self.exc = exc self.tb = '\n"""\n%s"""' % tb def __reduce__(self): @@ -166,7 +165,7 @@ class _SafeQueue(Queue): def _on_queue_feeder_error(self, e, obj): if isinstance(obj, _CallItem): - tb = traceback.format_exception(type(e), e, e.__traceback__) + tb = format_exception(type(e), e, e.__traceback__) e.__cause__ = _RemoteTraceback('\n"""\n{}"""'.format(''.join(tb))) work_item = self.pending_work_items.pop(obj.work_id, None) with self.shutdown_lock: @@ -384,7 +383,7 @@ class _ExecutorManagerThread(threading.Thread): result_item = result_reader.recv() is_broken = False except BaseException as e: - cause = traceback.format_exception(type(e), e, e.__traceback__) + cause = format_exception(type(e), e, e.__traceback__) elif wakeup_reader in ready: is_broken = False