missing allow_none=True in IPython.parallel

ipython_parallel/client/client.py

@@ -345,16 +345,15 b' class Client(HasTraits):'
     _ids = List()
     _connected=Bool(False)
     _ssh=Bool(False)
-    _context = Instance('zmq.Context')
+    _context = Instance('zmq.Context', allow_none=True)
     _config = Dict()
     _engines=Instance(util.ReverseDict, (), {})
-    # _hub_socket=Instance('zmq.Socket')
-    _query_socket=Instance('zmq.Socket')
-    _control_socket=Instance('zmq.Socket')
-    _iopub_socket=Instance('zmq.Socket')
-    _notification_socket=Instance('zmq.Socket')
-    _mux_socket=Instance('zmq.Socket')
-    _task_socket=Instance('zmq.Socket')
+    _query_socket=Instance('zmq.Socket', allow_none=True)
+    _control_socket=Instance('zmq.Socket', allow_none=True)
+    _iopub_socket=Instance('zmq.Socket', allow_none=True)
+    _notification_socket=Instance('zmq.Socket', allow_none=True)
+    _mux_socket=Instance('zmq.Socket', allow_none=True)
+    _task_socket=Instance('zmq.Socket', allow_none=True)
     _task_scheme=Unicode()
     _closed = False
     _ignored_control_replies=Integer(0)

ipython_parallel/client/view.py

@@ -109,7 +109,7 b' class View(HasTraits):'
     results = Dict()
     client = Instance('ipython_parallel.Client', allow_none=True)
 
-    _socket = Instance('zmq.Socket')
+    _socket = Instance('zmq.Socket', allow_none=True)
     _flag_names = List(['targets', 'block', 'track'])
     _in_sync_results = Bool(False)
     _targets = Any()