FilesExpand file tree

 master

/

__init__.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

75 lines (54 loc) · 2.15 KB

 master

/

__init__.py

Copy path

Top

File metadata and controls

• Code
• Blame

75 lines (54 loc) · 2.15 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

"""The IPython ZMQ-based parallel computing interface.

Authors:

* MinRK

"""

#-----------------------------------------------------------------------------

# Copyright (C) 2011 The IPython Development Team

#

# Distributed under the terms of the BSD License. The full license is in

# the file COPYING, distributed as part of this software.

#-----------------------------------------------------------------------------

#-----------------------------------------------------------------------------

# Imports

#-----------------------------------------------------------------------------

import os

import warnings

import zmq

from IPython.config.configurable import MultipleInstanceError

from IPython.zmq import check_for_zmq

if os.name == 'nt':

min_pyzmq = '2.1.7'

else:

min_pyzmq = '2.1.4'

check_for_zmq(min_pyzmq, 'IPython.parallel')

from IPython.utils.pickleutil import Reference

from .client.asyncresult import *

from .client.client import Client

from .client.remotefunction import *

from .client.view import *

from .controller.dependency import *

from .error import *

from .util import interactive

#-----------------------------------------------------------------------------

# Functions

#-----------------------------------------------------------------------------

def bind_kernel(**kwargs):

"""Bind an Engine's Kernel to be used as a full IPython kernel.

This allows a running Engine to be used simultaneously as a full IPython kernel

with the QtConsole or other frontends.

This function returns immediately.

"""

from IPython.zmq.ipkernel import IPKernelApp

from IPython.parallel.apps.ipengineapp import IPEngineApp

# first check for IPKernelApp, in which case this should be a no-op

# because there is already a bound kernel

if IPKernelApp.initialized() and isinstance(IPKernelApp._instance, IPKernelApp):

return

if IPEngineApp.initialized():

try:

app = IPEngineApp.instance()

except MultipleInstanceError:

pass

else:

return app.bind_kernel(**kwargs)

raise RuntimeError("bind_kernel be called from an IPEngineApp instance")