Commit 7a2aff57 authored by sumpfralle's avatar sumpfralle

reset the timeout counter for each worker process, if we found another item in the task queue


git-svn-id: https://pycam.svn.sourceforge.net/svnroot/pycam/trunk@754 bbaffbd6-741e-11dd-a85d-61de82d9cad9
parent a3a4f863
...@@ -242,6 +242,8 @@ def _handle_tasks(tasks, results, stats, cache, closing): ...@@ -242,6 +242,8 @@ def _handle_tasks(tasks, results, stats, cache, closing):
try: try:
start_time = time.time() start_time = time.time()
job_id, task_id, func, args = tasks.get(timeout=1.0) job_id, task_id, func, args = tasks.get(timeout=1.0)
# reset the timeout counter, if we found another item in the queue
timeout_counter = 0
real_args = [] real_args = []
for arg in args: for arg in args:
if isinstance(arg, ProcessDataCacheItemID): if isinstance(arg, ProcessDataCacheItemID):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment