code: def _mark_in_progress(self, node_id):
          
          self.queued.remove(node_id)
          self.in_progress.add(node_id)
docs: Mark the node as 'in progress'.
  
          Callers must hold the lock.
  
          :param str node_id: The node ID to mark as in progress.