def load_item(self, row):

        item = S3ImportItem(self)
        if not item.restore(row):
            self.error = item.error
            if item.load_parent is None:
                self.error_tree.append(deepcopy(item.element))
        # Update lookup lists
        item_id = item.item_id
        self.items[item_id] = item
        return item_id

    # -------------------------------------------------------------------------
Signals the writer that it can stop listening to the queue
dataset/ETHPy150Open sahana/eden/modules/s3/s3import.py/S3ImportJob.load_item--crossover with--dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/utils/mpwrappers.py/QueueStorageServiceSender.send_done