We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents b9d9912 + dd99e2f commit fd16fb3Copy full SHA for fd16fb3
pyres/worker.py
@@ -4,6 +4,7 @@
4
import os, sys
5
import json_parser as json
6
import commands
7
+import random
8
9
from pyres.exceptions import NoQueueError
10
from pyres.job import Job
@@ -167,6 +168,12 @@ def work(self, interval=5):
167
168
logger.info('Processing %s since %s' %
169
(job._queue, datetime.datetime.now()))
170
self.after_fork(job)
171
+
172
+ # re-seed the Python PRNG after forking, otherwise
173
+ # all job process will share the same sequence of
174
+ # random numbers
175
+ random.seed()
176
177
self.process(job)
178
os._exit(0)
179
self.child = None
0 commit comments