fix queue implementation

Signed-off-by: Dan Ryan <dan@danryan.co>
This commit is contained in:
Dan Ryan
2019-05-27 19:40:37 -04:00
parent 403a65105c
commit aa70ddb244
+5 -1
View File
@@ -751,9 +751,11 @@ def batch_install(deps_list, procs, failed_deps_queue,
use_pep517=not failed,
)
c.dep = dep
if dep.is_vcs or dep.editable:
c.block()
procs.put(c)
if procs.full():
if procs.full() or procs.qsize() == len(deps_list):
_cleanup_procs(procs, failed_deps_queue, retry=retry)
@@ -2500,6 +2502,8 @@ def do_run(command, args, three=None, python=False, pypi_mirror=None):
previous_pipenv_active_value = os.environ.get("PIPENV_ACTIVE")
os.environ["PIPENV_ACTIVE"] = vistir.misc.fs_str("1")
os.environ.pop("PIP_SHIMS_BASE_MODULE", None)
try:
script = project.build_script(command, args)
cmd_string = ' '.join([script.command] + script.args)