aboutsummaryrefslogtreecommitdiffhomepage
path: root/tensorflow/contrib/data/kernels/threadpool_dataset_op.cc
diff options
context:
space:
mode:
Diffstat (limited to 'tensorflow/contrib/data/kernels/threadpool_dataset_op.cc')
-rw-r--r--tensorflow/contrib/data/kernels/threadpool_dataset_op.cc11
1 files changed, 6 insertions, 5 deletions
diff --git a/tensorflow/contrib/data/kernels/threadpool_dataset_op.cc b/tensorflow/contrib/data/kernels/threadpool_dataset_op.cc
index 4dc69dc2ef..ab584504a0 100644
--- a/tensorflow/contrib/data/kernels/threadpool_dataset_op.cc
+++ b/tensorflow/contrib/data/kernels/threadpool_dataset_op.cc
@@ -130,11 +130,13 @@ class ThreadPoolDatasetOp : public UnaryDatasetOpKernel {
}
private:
- class Dataset : public GraphDatasetBase {
+ class Dataset : public DatasetBase {
public:
Dataset(OpKernelContext* ctx, const DatasetBase* input,
ThreadPoolResource* threadpool)
- : GraphDatasetBase(ctx), input_(input), threadpool_(threadpool) {
+ : DatasetBase(DatasetContext(ctx)),
+ input_(input),
+ threadpool_(threadpool) {
input_->Ref();
threadpool_->Ref();
}
@@ -165,9 +167,8 @@ class ThreadPoolDatasetOp : public UnaryDatasetOpKernel {
Status AsGraphDefInternal(SerializationContext* ctx,
DatasetGraphDefBuilder* b,
Node** output) const override {
- return errors::Unimplemented(
- "Cannot currently serialize the thread pool for a "
- "ThreadPoolDataset.");
+ return errors::Unimplemented("%s does not support serialization",
+ DebugString());
}
private: