x/anvil
Code Issues Proposed changes

Remove venv '_worker' function not used anymore

Browse Source 
This moved to async.py and this copy was left behind.

This removes it...

Change-Id: I8dbe9f9ba5b9a5a6c75de332ee13beb7f4d31a61
This commit is contained in:
Joshua Harlow 2015-07-08 18:10:21 -07:00
parent 77d14dc5cc
commit 62efcbcd29
1 changed files with 0 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
anvil/packaging/venv.py
View File

@ -19,7 +19,6 @@ import functools
import itertools import itertools
import os import os
import re import re
import sys
import tarfile import tarfile
import six import six
@ -36,35 +35,6 @@ from anvil.packaging import base
from anvil.packaging.helpers import pip_helper from anvil.packaging.helpers import pip_helper
LOG = logging.getLogger(__name__) LOG = logging.getLogger(__name__)
TOMBSTONE = object()
def _worker(ident, shared_death, queue, futs):
while not shared_death.is_set():
w = queue.get()
if w is TOMBSTONE:
queue.put(w)
for fut in futs:
fut.cancel()
break
else:
func, fut = w
if fut.set_running_or_notify_cancel():
try:
result = func()
except BaseException:
LOG.exception("Worker %s dying...", ident)
exc_type, exc_val, exc_tb = sys.exc_info()
if six.PY2:
fut.set_exception_info(exc_val, exc_tb)
else:
fut.set_exception(exc_val)
# Stop all other workers from doing any more work...
shared_death.set()
for fut in futs:
fut.cancel()
else:
fut.set_result(result)
def _on_finish(what, time_taken): def _on_finish(what, time_taken):