def METHOD_NAME(self, name: str):
    consumer = DatasetRecordsConsumer(
        name=name,
        api=self._api,
        upload_interval=self._log_interval,
    )
    consumer.start()
    return consumer