def apply_async(pool, fun, args, run_dill_encoded=run_dill_encoded): return pool.apply_async(run_dill_encoded, (dill.dumps((fun, args)),))