From ce4ddd78658a07a9130e90a97f194a116fd508fc Mon Sep 17 00:00:00 2001 From: minqiyang Date: Thu, 26 Jul 2018 15:48:05 +0800 Subject: [PATCH] Add debug info --- python/paddle/reader/decorator.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/python/paddle/reader/decorator.py b/python/paddle/reader/decorator.py index 4b1fe94222..ff64a1a5af 100644 --- a/python/paddle/reader/decorator.py +++ b/python/paddle/reader/decorator.py @@ -325,6 +325,14 @@ def xmap_readers(mapper, reader, process_num, buffer_size, order=False): else: yield sample + assert finish == process_num + for w in workers: + print('join worker: ', w) + print('join worker: ', w.is_alive()) + w.join() + print('join worker: ', w.is_alive()) + del workers + return xreader -- GitLab