def __init__(self, shard_state):
    self._shard_state = shard_state
Replaces the trajectory's service with a queue sender and starts the queue process.
dataset/ETHPy150Open livid/v2ex/mapreduce/context.py/Counters.__init__--crossover with--dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py/MultiprocContext._prepare_pipe