Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[MPI] Unidist hungs when finishing work #313

Open
Retribution98 opened this issue Jun 30, 2023 · 0 comments
Open

[MPI] Unidist hungs when finishing work #313

Retribution98 opened this issue Jun 30, 2023 · 0 comments
Labels
bug 🦗 Something isn't working MPI MPI backend related issues

Comments

@Retribution98
Copy link
Collaborator

Unidist returns a result, but one of the workers cannot finish the job.

import unidist
import time

@unidist.remote
def g(number):
    time.sleep(1)
    return number**2

@unidist.remote
def f():
    results = []
    for i in range(10):
        results.append(unidist.get(g.remote(i)))
    print('The f faster than faster_fn')
    return results

@unidist.remote
def faster_fn():
    time.sleep(0.1)
    print('The faster_fn faster than f')

unidist.init()
ref1 = f.remote()
ref2 = faster_fn.remote()
unidist.wait([ref1, ref2], num_returns=1)

The reproducer should be running with UNIDIST_CPUS=5

@YarShev YarShev added MPI MPI backend related issues bug 🦗 Something isn't working labels Jul 1, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug 🦗 Something isn't working MPI MPI backend related issues
Projects
None yet
Development

No branches or pull requests

2 participants