Show More
@@ -16,6 +16,7 b' from types import ModuleType' | |||||
16 | from IPython.parallel.client.asyncresult import AsyncResult |
|
16 | from IPython.parallel.client.asyncresult import AsyncResult | |
17 | from IPython.parallel.error import UnmetDependency |
|
17 | from IPython.parallel.error import UnmetDependency | |
18 | from IPython.parallel.util import interactive |
|
18 | from IPython.parallel.util import interactive | |
|
19 | from IPython.utils import py3compat | |||
19 |
|
20 | |||
20 | class depend(object): |
|
21 | class depend(object): | |
21 | """Dependency decorator, for use with tasks. |
|
22 | """Dependency decorator, for use with tasks. | |
@@ -65,9 +66,10 b' class dependent(object):' | |||||
65 | raise UnmetDependency() |
|
66 | raise UnmetDependency() | |
66 | return self.f(*args, **kwargs) |
|
67 | return self.f(*args, **kwargs) | |
67 |
|
68 | |||
68 | @property |
|
69 | if not py3compat.PY3: | |
69 | def __name__(self): |
|
70 | @property | |
70 | return self.func_name |
|
71 | def __name__(self): | |
|
72 | return self.func_name | |||
71 |
|
73 | |||
72 | @interactive |
|
74 | @interactive | |
73 | def _require(*names): |
|
75 | def _require(*names): |
@@ -188,7 +188,7 b' class ShellSocketChannel(ZMQSocketChannel):' | |||||
188 | def run(self): |
|
188 | def run(self): | |
189 | """The thread's main activity. Call start() instead.""" |
|
189 | """The thread's main activity. Call start() instead.""" | |
190 | self.socket = self.context.socket(zmq.DEALER) |
|
190 | self.socket = self.context.socket(zmq.DEALER) | |
191 | self.socket.setsockopt(zmq.IDENTITY, self.session.session) |
|
191 | self.socket.setsockopt(zmq.IDENTITY, self.session.session.encode("ascii")) | |
192 | self.socket.connect('tcp://%s:%i' % self.address) |
|
192 | self.socket.connect('tcp://%s:%i' % self.address) | |
193 | self.iostate = POLLERR|POLLIN |
|
193 | self.iostate = POLLERR|POLLIN | |
194 | self.ioloop.add_handler(self.socket, self._handle_events, |
|
194 | self.ioloop.add_handler(self.socket, self._handle_events, | |
@@ -394,8 +394,8 b' class SubSocketChannel(ZMQSocketChannel):' | |||||
394 | def run(self): |
|
394 | def run(self): | |
395 | """The thread's main activity. Call start() instead.""" |
|
395 | """The thread's main activity. Call start() instead.""" | |
396 | self.socket = self.context.socket(zmq.SUB) |
|
396 | self.socket = self.context.socket(zmq.SUB) | |
397 | self.socket.setsockopt(zmq.SUBSCRIBE,'') |
|
397 | self.socket.setsockopt(zmq.SUBSCRIBE,b'') | |
398 | self.socket.setsockopt(zmq.IDENTITY, self.session.session) |
|
398 | self.socket.setsockopt(zmq.IDENTITY, self.session.session.encode("ascii")) | |
399 | self.socket.connect('tcp://%s:%i' % self.address) |
|
399 | self.socket.connect('tcp://%s:%i' % self.address) | |
400 | self.iostate = POLLIN|POLLERR |
|
400 | self.iostate = POLLIN|POLLERR | |
401 | self.ioloop.add_handler(self.socket, self._handle_events, |
|
401 | self.ioloop.add_handler(self.socket, self._handle_events, | |
@@ -483,7 +483,7 b' class StdInSocketChannel(ZMQSocketChannel):' | |||||
483 | def run(self): |
|
483 | def run(self): | |
484 | """The thread's main activity. Call start() instead.""" |
|
484 | """The thread's main activity. Call start() instead.""" | |
485 | self.socket = self.context.socket(zmq.DEALER) |
|
485 | self.socket = self.context.socket(zmq.DEALER) | |
486 | self.socket.setsockopt(zmq.IDENTITY, self.session.session) |
|
486 | self.socket.setsockopt(zmq.IDENTITY, self.session.session.encode("ascii")) | |
487 | self.socket.connect('tcp://%s:%i' % self.address) |
|
487 | self.socket.connect('tcp://%s:%i' % self.address) | |
488 | self.iostate = POLLERR|POLLIN |
|
488 | self.iostate = POLLERR|POLLIN | |
489 | self.ioloop.add_handler(self.socket, self._handle_events, |
|
489 | self.ioloop.add_handler(self.socket, self._handle_events, | |
@@ -562,7 +562,7 b' class HBSocketChannel(ZMQSocketChannel):' | |||||
562 |
|
562 | |||
563 | def _create_socket(self): |
|
563 | def _create_socket(self): | |
564 | self.socket = self.context.socket(zmq.REQ) |
|
564 | self.socket = self.context.socket(zmq.REQ) | |
565 | self.socket.setsockopt(zmq.IDENTITY, self.session.session) |
|
565 | self.socket.setsockopt(zmq.IDENTITY, self.session.session.encode("ascii")) | |
566 | self.socket.connect('tcp://%s:%i' % self.address) |
|
566 | self.socket.connect('tcp://%s:%i' % self.address) | |
567 | self.poller = zmq.Poller() |
|
567 | self.poller = zmq.Poller() | |
568 | self.poller.register(self.socket, zmq.POLLIN) |
|
568 | self.poller.register(self.socket, zmq.POLLIN) |
@@ -48,7 +48,7 b' from IPython.utils.importstring import import_item' | |||||
48 | from IPython.utils.jsonutil import extract_dates, squash_dates, date_default |
|
48 | from IPython.utils.jsonutil import extract_dates, squash_dates, date_default | |
49 | from IPython.utils.py3compat import str_to_bytes |
|
49 | from IPython.utils.py3compat import str_to_bytes | |
50 | from IPython.utils.traitlets import (CBytes, Unicode, Bool, Any, Instance, Set, |
|
50 | from IPython.utils.traitlets import (CBytes, Unicode, Bool, Any, Instance, Set, | |
51 | DottedObjectName) |
|
51 | DottedObjectName, CUnicode) | |
52 |
|
52 | |||
53 | #----------------------------------------------------------------------------- |
|
53 | #----------------------------------------------------------------------------- | |
54 | # utility functions |
|
54 | # utility functions | |
@@ -239,10 +239,10 b' class Session(Configurable):' | |||||
239 | else: |
|
239 | else: | |
240 | self.unpack = import_item(str(new)) |
|
240 | self.unpack = import_item(str(new)) | |
241 |
|
241 | |||
242 |
session = C |
|
242 | session = CUnicode(u'', config=True, | |
243 | help="""The UUID identifying this session.""") |
|
243 | help="""The UUID identifying this session.""") | |
244 | def _session_default(self): |
|
244 | def _session_default(self): | |
245 |
return |
|
245 | return unicode(uuid.uuid4()) | |
246 |
|
246 | |||
247 | username = Unicode(os.environ.get('USER',u'username'), config=True, |
|
247 | username = Unicode(os.environ.get('USER',u'username'), config=True, | |
248 | help="""Username for the Session. Default is your system username.""") |
|
248 | help="""Username for the Session. Default is your system username.""") |
General Comments 0
You need to be logged in to leave comments.
Login now