linar-jether

from __future__ import absolute_import, division, print_function

import multiprocessing
import pickle
from multiprocessing.pool import ThreadPool

from celery import shared_task
from dask.local import get_async  # TODO: get better get
from dask.context import _globals
from dask.optimize import fuse, cull