def _execute(self, ifile, process):
        self._record_writer.write_records(process(self._records(ifile)))
        self.finish()
Waits for a shutdown signal from the child threads
dataset/ETHPy150Open splunk/splunk-sdk-python/splunklib/searchcommands/search_command.py/SearchCommand._execute--crossover with--dataset/ETHPy150Open StorjOld/downstream-farmer/downstream_farmer/utils.py/ThreadManager.wait_for_shutdown