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

[Bug]: pw.run() never terminates when used with multiprocessing #54

Closed
KamilPiechowiak opened this issue May 17, 2024 · 1 comment
Closed
Labels
bug Something isn't working

Comments

@KamilPiechowiak
Copy link
Contributor

Steps to reproduce

This simple program never terminates:

import pathway as pw
import multiprocessing

def local_run():
    pw.run(monitoring_level=pw.MonitoringLevel.NONE)

p = multiprocessing.Process(target=local_run)
p.start()
p.join()

(local_run added to disable monitoring)
It is caused by a deadlock on logger's flush. This receiver never receives the message it waits for.
Disabling the logger flushing makes program terminate correctly.

Relevant log output

no output

What did you expect to happen?

The program to finish.

Version

0.11.1

Docker Versions (if used)

No response

OS

Linux

On which CPU architecture did you run Pathway?

x86-64

@KamilPiechowiak KamilPiechowiak added the bug Something isn't working label May 17, 2024
@KamilPiechowiak
Copy link
Contributor Author

Fixed in 0.14.0.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

1 participant