fix TrackerServer stop

douban · Jul 23, 2018 · 0401171 · 0401171
1 parent 4e09628
commit 0401171
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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