we need to evaluate the result across many random seeds, so each task needs to log the result independently.
Ohh that kind of makes sense to me π
Yes I'm also getting:
/usr/local/lib/python3.6/multiprocessing/semaphore_tracker.py:143: UserWarning: semaphore_tracker: There appear to be 74 leaked semaphores to clean up at shutdown
len(cache))
Not sure about that ...
Hi @<1523710701275713536:profile|PompousHawk82> , can you try with the latest RC?
there is a semaphore warning, not sure if itβs related
Can you resend it?
Is the Task marked as closed when the process ends ?
works most of time, this occurs only few times
Hmm so the Task.init should be called on the main process, this way the subprocess knows the Task is already created (you can call Task.init twice to get the task object). I wonder if we somehow can communicate between the sub processes without initializing in the main one...
So what if i want three tasks running in parallel, should i Task.init in the main process and change the task name in the sub process?
one quick question is that do i need to do some task.close() at the end of each process?
No need, it should auto close it if you started it with Task.init (or the agent executed it)
Let me know if it solved it, if it did I'll make sure we push the RC
Wouldn't it make sense to use a single one ?
now it has log, but only the initial one
So the subprocesses are not logged ?
Let me check, see what can be learned ...
Not sure on the cause but if you do:
mp.set_start_method('fork', force=True)
There is no semaphore leakage
and one experiment takes 40 hours to run, so i let them run in parallel
in my case, we need to evaluate the result across many random seeds, so each task needs to log the result independently.