Skip to content

Commit 36a0806

Browse files
authored
Merge pull request #304 from raysect/bugfix/multicore_engine
Replacing time.time_ns() with time.time()
2 parents c24f119 + c04bc81 commit 36a0806

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

raysect/core/workflow.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ def _producer(self, tasks, job_queue, stored_tasks_per_job):
237237

238238
# split tasks into jobs and dispatch to workers
239239
requests = -self.processes # ignore the initial jobs, the requests are instantaneous
240-
start_time = time.time_ns()
240+
start_time = time.time()
241241
while tasks:
242242

243243
# assemble job
@@ -255,7 +255,7 @@ def _producer(self, tasks, job_queue, stored_tasks_per_job):
255255
# if enabled, auto adjust tasks per job to keep target requests per second
256256
if self._auto_tasks_per_job:
257257

258-
elapsed_time = 1e-9 * (time.time_ns() - start_time)
258+
elapsed_time = (time.time() - start_time)
259259
if elapsed_time > min_time and requests > min_requests:
260260

261261
# re-normalise the tasks per job based on previous work to propose a new value
@@ -268,7 +268,7 @@ def _producer(self, tasks, job_queue, stored_tasks_per_job):
268268

269269
# reset counters
270270
requests = 0
271-
start_time = time.time_ns()
271+
start_time = time.time()
272272

273273
# pass back new value
274274
stored_tasks_per_job.value = tasks_per_job

0 commit comments

Comments
 (0)