Did I find the right examples for you? yes no

All Samples(5)  |  Call(3)  |  Derive(0)  |  Import(2)

src/l/s/lsd-HEAD/src/lsd/tasks.py   lsd(Download)
import bhpix
import sys
from utils import as_columns, gnomonic, gc_dist, unpack_callable
from colgroup import ColGroup
from join_ops import IntoWriter, DB
 
###################################################################
## Sky-coverage computation
def _coverage_mapper(qresult, dx, filter):
	filter, filter_args = unpack_callable(filter)

src/l/s/lsd-HEAD/src/lsd/join_ops.py   lsd(Download)
def _mapper(partspec, mapper, qengine, include_cached):
	(group_cell_id, cell_list) = partspec
	mapper, mapper_args = utils.unpack_callable(mapper)
 
	# Pass on to mapper (and yield its results)

src/l/s/lsd-HEAD/src/lsd/pool2.py   lsd(Download)
import signal
import getpass
from utils import unpack_callable
 
logger = logging.getLogger('lsd.pool2')
 
		for i, K in enumerate(kernels):
			K_fun, K_args = unpack_callable(K)
			last_step = (i + 1 == len(kernels))
			stage = where(i == 0, 'map', 'reduce')