diff --git a/dpark/tracker.py b/dpark/tracker.py index 2c99fe56..95fd3819 100644 --- a/dpark/tracker.py +++ b/dpark/tracker.py @@ -62,7 +62,7 @@ def stop(self): confirm_msg = sock.recv_pyobj() sock.close() self.thread.join() - if self.ctx is None: + if self.ctx is not None: self.ctx.destroy() self.ctx = None return confirm_msg