def start_working_on_subjob(self, build_id, subjob_id, atomic_commands):
        if build_id != self._current_build_id:
            raise BadRequestError('Attempted to start subjob {} for build {}, '
                                  'but current build id is {}.'.format(subjob_id, build_id, self._current_build_id))

        # get idle executor from queue to claim it as in-use (or block until one is available)
        executor = self._idle_executors.get()

        # Start a thread to execute the job (after waiting for setup to complete)
        SafeThread(
            target=self._execute_subjob,
            args=(build_id, subjob_id, executor, atomic_commands),
            name='Bld{}-Sub{}'.format(build_id, subjob_id),
        ).start()

        self._logger.info('Slave ({}:{}) has received subjob. (Build {}, Subjob {})', self.host, self.port, build_id,
                          subjob_id)
        return {'executor_id': executor.id}
Cache key.
dataset/ETHPy150Open box/ClusterRunner/app/slave/cluster_slave.py/ClusterSlave.start_working_on_subjob--crossover with--dataset/ETHPy150Open OP2/PyOP2/pyop2/caching.py/Cached.cache_key