Wit doesn't work with multiprocessing anymore

[walchko]

Hello, I use to be able to use wit with multiprocessing but recently when I started using wit again, this fails now. I made a simple example that shows the failure. I created 2 classes, one with multiprocessing and one without. The multiprocessing class hangs up on wit.query_text() for some reason. If you comment it out and replace it with something like print 'hello!' it works fine. What happened to wit to break this?

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import wit
import multiprocessing as mp
import time

token = 'my token'

# a class with multiprocessing
class MP(mp.Process):
    def __init__(self):
        mp.Process.__init__(self)
        wit.init()

    def run(self):
        while True:
            ans = wit.text_query('hello',token)
            print ans
            time.sleep(2)

# just a normal class
class nonMP(object):
    def __init__(self):
        wit.init()

    def run(self):
        while True:
            ans = wit.text_query('hello',token)
            print ans
            time.sleep(2)

    def start(self):
        self.run()
    def join(self):
        a=1

# w = nonMP() # no multiprocessing
w = MP() # with multiprocessing
w.start()
w.join()

Platform: OSX 10.11.1
Python: 2.7.11

[blandinw]

Thanks @walchko!
We moved to a pure Python version of the library, which should have fixed this issue. The code below works for me (pywit 2.0). Feel free to reopen.

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import wit
import multiprocessing as mp
import time

token = 'token'

# a class with multiprocessing
class MP(mp.Process):
    def __init__(self):
        mp.Process.__init__(self)

    def run(self):
        while True:
            ans = wit.message(token, 'drive to twitter')
            print ans
            time.sleep(2)

# just a normal class
class nonMP(object):
    def __init__(self):
        pass

    def run(self):
        while True:
            ans = wit.text_query('hello',token)
            print ans
            time.sleep(2)

    def start(self):
        self.run()
    def join(self):
        a=1

# w = nonMP() # no multiprocessing
w = MP() # with multiprocessing
w.start()
w2 = MP()
w2.start()
w.join()
w2.join()