def put_all_records(self):
        precs = self._pending_records
        self._pending_records = []
        self.put_records(precs)
        self.total_records += len(precs)
        return len(precs)
Create a PilotData 
dataset/ETHPy150Open awslabs/kinesis-poster-worker/poster.py/KinesisPoster.put_all_records--crossover with--dataset/ETHPy150Open saga-project/BigJob/pilot/impl/pilotdata_manager.py/PilotDataService.create_pilot