Commitbae61de

committed

self.fresh_process = False only after successfully getting from result queue

1 parentfe24fd7 commitbae61deCopy full SHA for bae61de

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -88,6 +88,7 @@ def _await_result(self):`
`88`	`88`	`try:`
`89`	`89`	`result=self.result_queue.get(timeout=timeout)`
`90`	`90`	`assert (resultisNone)==self.fresh_process`
	`91`	`+self.fresh_process=False`
`91`	`92`	`exceptqueue.Empty:`
`92`	`93`	`alive=self.process.is_alive()`
`93`	`94`	`log.info(f"Process{alive=}")`
`@@ -102,7 +103,6 @@ def _await_result(self):`
`102`	`103`	`],`
`103`	`104`	`output='The process died.',`
`104`	`105`	`)`
`105`		`-self.fresh_process=False`
`106`	`106`	`returnresult`
`107`	`107`
`108`	`108`

Comments

(0)