code: def add_node_collection(self, node, collection):
          
  
          # Check that add_node() was called on the node before
          assert node in self.assigned_work
  
          # A new node has been added later, perhaps an original one died.
          if self.collection_is_completed:
  
              # Assert that .schedule() should have been called by now
              assert self.collection
  
              # Check that the new collection matches the official collection
              if collection != self.collection:
  
                  other_node = next(iter(self.registered_collections.keys()))
  
                  msg = report_collection_diff(
                      self.collection, collection, other_node.gateway.id, node.gateway.id
                  )
                  self.log(msg)
                  return
  
          self.registered_collections[node] = list(collection)
docs: Add the collected test items from a node.
  
          The collection is stored in the ``.registered_collections`` dictionary.
  
          Called by the hook:
  
          - ``DSession.worker_collectionfinish``.