jupyter_threading.py

from threading import Thread

class QueryFuture(Thread):
    def __init__(self, q):
        self.q = q
        super().__init__()

    def run(self):
        self.docs = presto.execute_response(self.q)

def run_query(q):
    w = QueryFuture(q)
    w.start()
    return w