Skip to content

Commit 7401ed8

Browse files
committed
fix bug
1 parent 1f08bec commit 7401ed8

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

metaflow/plugins/pypi/conda_environment.py

+3-4
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,6 @@ def _path(url, local_path):
190190
# 4. Start PyPI solves in parallel after each conda environment is created
191191
# 5. Download PyPI packages sequentially
192192
# 6. Create and cache PyPI environments in parallel
193-
194193
with ThreadPoolExecutor() as executor:
195194
# Start all conda solves in parallel
196195
conda_futures = [
@@ -213,14 +212,14 @@ def _path(url, local_path):
213212

214213
# Queue PyPI solve to start after conda create
215214
if result[0] in pypi_envs:
215+
# solve pypi envs uniquely
216+
pypi_env = pypi_envs.pop(result[0])
216217

217218
def pypi_solve(env):
218219
create_future.result() # Wait for conda create
219220
return solve(*env, "pypi")
220221

221-
pypi_futures.append(
222-
executor.submit(pypi_solve, pypi_envs[result[0]])
223-
)
222+
pypi_futures.append(executor.submit(pypi_solve, pypi_env))
224223

225224
# Process PyPI results sequentially for downloads
226225
for solve_future in pypi_futures:

0 commit comments

Comments
 (0)