pep8: Add compliance with rule E261 to parallel.py.

This commit is contained in:
Aditya Bansal 2017-05-07 20:37:44 +05:30 committed by Tim Abbott
parent cbaace87cd
commit d561c758cd
1 changed files with 2 additions and 2 deletions

View File

@ -9,7 +9,7 @@ import errno
def run_parallel(job, data, threads=6):
# type: (Any, Iterable[Any], int) -> Generator[Tuple[int, Any], None, None]
pids = {} # type: Dict[int, Any]
pids = {} # type: Dict[int, Any]
def wait_for_one():
# type: () -> Tuple[int, Any]
@ -29,7 +29,7 @@ def run_parallel(job, data, threads=6):
except OSError as e:
if e.errno != errno.EBADF:
raise
sys.stdin = open("/dev/null", "r") # type: ignore # py2 and py3 stubs are not compatible
sys.stdin = open("/dev/null", "r") # type: ignore # py2 and py3 stubs are not compatible
os._exit(job(item))
pids[pid] = item