Show More
@@ -304,15 +304,22 b' class IPEngineApp(BaseParallelApplication):' | |||||
304 |
|
304 | |||
305 |
|
305 | |||
306 | try: |
|
306 | try: | |
307 | exec_lines = config.Kernel.exec_lines |
|
307 | exec_lines = config.IPKernelApp.exec_lines | |
308 | except AttributeError: |
|
308 | except AttributeError: | |
309 | config.Kernel.exec_lines = [] |
|
309 | try: | |
310 |
exec_lines = config. |
|
310 | exec_lines = config.InteractiveShellApp.exec_lines | |
|
311 | except AttributeError: | |||
|
312 | exec_lines = config.IPKernelApp.exec_lines = [] | |||
|
313 | try: | |||
|
314 | exec_files = config.IPKernelApp.exec_files | |||
|
315 | except AttributeError: | |||
|
316 | try: | |||
|
317 | exec_files = config.InteractiveShellApp.exec_files | |||
|
318 | except AttributeError: | |||
|
319 | exec_files = config.IPKernelApp.exec_files = [] | |||
311 |
|
320 | |||
312 | if self.startup_script: |
|
321 | if self.startup_script: | |
313 | enc = sys.getfilesystemencoding() or 'utf8' |
|
322 | exec_files.append(self.startup_script) | |
314 | cmd="execfile(%r)" % self.startup_script.encode(enc) |
|
|||
315 | exec_lines.append(cmd) |
|
|||
316 | if self.startup_command: |
|
323 | if self.startup_command: | |
317 | exec_lines.append(self.startup_command) |
|
324 | exec_lines.append(self.startup_command) | |
318 |
|
325 |
@@ -34,7 +34,7 b' from IPython.parallel.factory import RegistrationFactory' | |||||
34 | from IPython.parallel.util import disambiguate_url |
|
34 | from IPython.parallel.util import disambiguate_url | |
35 |
|
35 | |||
36 | from IPython.zmq.session import Message |
|
36 | from IPython.zmq.session import Message | |
37 | from IPython.zmq.ipkernel import Kernel |
|
37 | from IPython.zmq.ipkernel import Kernel, IPKernelApp | |
38 |
|
38 | |||
39 | class EngineFactory(RegistrationFactory): |
|
39 | class EngineFactory(RegistrationFactory): | |
40 | """IPython engine""" |
|
40 | """IPython engine""" | |
@@ -204,10 +204,15 b' class EngineFactory(RegistrationFactory):' | |||||
204 | self.kernel = Kernel(config=self.config, int_id=self.id, ident=self.ident, session=self.session, |
|
204 | self.kernel = Kernel(config=self.config, int_id=self.id, ident=self.ident, session=self.session, | |
205 | control_stream=control_stream, shell_streams=shell_streams, iopub_socket=iopub_socket, |
|
205 | control_stream=control_stream, shell_streams=shell_streams, iopub_socket=iopub_socket, | |
206 | loop=loop, user_ns=self.user_ns, log=self.log) |
|
206 | loop=loop, user_ns=self.user_ns, log=self.log) | |
|
207 | ||||
207 | self.kernel.shell.display_pub.topic = cast_bytes('engine.%i.displaypub' % self.id) |
|
208 | self.kernel.shell.display_pub.topic = cast_bytes('engine.%i.displaypub' % self.id) | |
208 | self.kernel.start() |
|
|||
209 |
|
209 | |||
|
210 | # FIXME: This is a hack until IPKernelApp and IPEngineApp can be fully merged | |||
|
211 | app = IPKernelApp(config=self.config, shell=self.kernel.shell, kernel=self.kernel, log=self.log) | |||
|
212 | app.init_profile_dir() | |||
|
213 | app.init_code() | |||
210 |
|
214 | |||
|
215 | self.kernel.start() | |||
211 | else: |
|
216 | else: | |
212 | self.log.fatal("Registration Failed: %s"%msg) |
|
217 | self.log.fatal("Registration Failed: %s"%msg) | |
213 | raise Exception("Registration Failed: %s"%msg) |
|
218 | raise Exception("Registration Failed: %s"%msg) |
General Comments 0
You need to be logged in to leave comments.
Login now