def _on_new_id(self, new_id):
		try:
			path = id_to_item_path(self.path, new_id)
			get_logger().info("DistributedBag._on_new_id %s" % (path))
			with self.lock:
				self.ids.add(new_id)
				deleted = Deleted(
					self.connection, path, [self._process_deleted])
				self.deletion_handlers[new_id] = deleted
				for callback in self.add_callbacks:
					callback(self, new_id)
		except:
			exc_class, exc, tback = sys.exc_info()
			sys.stderr.write(str(exc_class) + "\n")
			traceback.print_tb(tback)
			raise exc_class, exc, tback
The generated API documentation includes the input schema if it's an
dataset/ETHPy150Open Knewton/pettingzoo-python/pettingzoo/dbag.py/DistributedBag._on_new_id--crossover with--dataset/ETHPy150Open ClusterHQ/flocker/flocker/restapi/docs/test/test_publicapi.py/MakeRstTests.test_inputArraySchema