Commit689ac9e

authored

Store errors in thread status (#1263)

1 parent75d341b commit689ac9eCopy full SHA for 689ac9e

File tree

-3

lines changed

-3

lines changed

Lines changed: 2 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -187,10 +187,9 @@ def streaming_worker(worker_threads, model, **kwargs):`
`187`	`187`	`worker_threads.update_thread(thread_id,"Error setting data")`
`188`	`188`	`try:`
`189`	`189`	`model.generate(**kwargs)`
`190`		`-exceptBaseExceptionaserror:`
`191`		`-print(f"Error in streaming_worker:{error}",file=sys.stderr)`
`192`		`-finally:`
`193`	`190`	`worker_threads.delete_thread(thread_id)`
	`191`	`+exceptBaseExceptionaserror:`
	`192`	`+worker_threads.update_thread(thread_id,f"Error in streaming_worker:{error}")`
`194`	`193`
`195`	`194`
`196`	`195`	`classGGMLPipeline(object):`

Comments

(0)