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.
Steps to reproduce
This simple program never terminates:
(
local_runadded 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
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