def pig_script_path(self):
        raise NotImplementedError("subclass should define pig_script_path")
Start workers and put into queue
dataset/ETHPy150Open spotify/luigi/luigi/contrib/pig.py/PigJobTask.pig_script_path--crossover with--dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/thrift-0.9.1/src/server/TProcessPoolServer.py/TProcessPoolServer.serve