Skip to content

Commit

Permalink
No public description
Browse files Browse the repository at this point in the history
Tested:
PiperOrigin-RevId: 659827895
Change-Id: I96460aacf7dfda14ea6a40865078c10a66766c51
  • Loading branch information
Reverb Team authored and copybara-github committed Aug 6, 2024
1 parent 6a0dcf4 commit 12cee6a
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 13 deletions.
2 changes: 1 addition & 1 deletion reverb/cc/ops/client.cc
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ class ClientHandleOp : public tensorflow::ResourceOpKernel<ClientResource> {
private:
tensorflow::Status CreateResource(ClientResource** ret) override {
*ret = new ClientResource(server_address_);
return tensorflow::OkStatus();
return absl::OkStatus();
}

std::string server_address_;
Expand Down
6 changes: 3 additions & 3 deletions reverb/cc/ops/pattern_dataset.cc
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ class ReverbPatternDatasetOp : public tensorflow::data::UnaryDatasetOpKernel {
std::vector<const tensorflow::data::DatasetBase*>* inputs)
const override {
inputs->push_back(input_);
return tensorflow::OkStatus();
return absl::OkStatus();
}

tensorflow::Status CheckExternalState() const override {
Expand Down Expand Up @@ -223,7 +223,7 @@ class ReverbPatternDatasetOp : public tensorflow::data::UnaryDatasetOpKernel {
},
output));

return tensorflow::OkStatus();
return absl::OkStatus();
}

private:
Expand Down Expand Up @@ -298,7 +298,7 @@ class ReverbPatternDatasetOp : public tensorflow::data::UnaryDatasetOpKernel {
*out_tensors = data_.front();
data_.pop_front();
}
return tensorflow::OkStatus();
return absl::OkStatus();
}

protected:
Expand Down
10 changes: 5 additions & 5 deletions reverb/cc/ops/timestep_dataset.cc
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ class ReverbTimestepDatasetOp : public tensorflow::data::DatasetOpKernel {
tensorflow::Status InputDatasets(
std::vector<const DatasetBase*>* inputs) const override {
inputs->clear();
return tensorflow::OkStatus();
return absl::OkStatus();
}

protected:
Expand Down Expand Up @@ -170,7 +170,7 @@ class ReverbTimestepDatasetOp : public tensorflow::data::DatasetOpKernel {
},
output));

return tensorflow::OkStatus();
return absl::OkStatus();
}

private:
Expand Down Expand Up @@ -248,17 +248,17 @@ class ReverbTimestepDatasetOp : public tensorflow::data::DatasetOpKernel {
*end_of_sequence = false;
*out_tensors = Sampler::WithInfoTensors(*info, std::move(data));
rate_limited_ = info->rate_limited();
return tensorflow::OkStatus();
return absl::OkStatus();
} else if (sampler_options_.rate_limiter_timeout <
absl::InfiniteDuration() &&
errors::IsRateLimiterTimeout(status)) {
*end_of_sequence = true;
return tensorflow::OkStatus();
return absl::OkStatus();
} else if (absl::IsOutOfRange(status) &&
sampler_options_.max_samples > 0) {
// `max_samples` samples have already been returned by the iterator.
*end_of_sequence = true;
return tensorflow::OkStatus();
return absl::OkStatus();
} else {
return ToTensorflowStatus(status);
}
Expand Down
8 changes: 4 additions & 4 deletions reverb/cc/ops/trajectory_dataset.cc
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ class ReverbTrajectoryDatasetOp : public tensorflow::data::DatasetOpKernel {
tensorflow::Status InputDatasets(
std::vector<const DatasetBase*>* inputs) const override {
inputs->clear();
return tensorflow::OkStatus();
return absl::OkStatus();
}

protected:
Expand Down Expand Up @@ -170,7 +170,7 @@ class ReverbTrajectoryDatasetOp : public tensorflow::data::DatasetOpKernel {
},
output));

return tensorflow::OkStatus();
return absl::OkStatus();
}

private:
Expand Down Expand Up @@ -252,12 +252,12 @@ class ReverbTrajectoryDatasetOp : public tensorflow::data::DatasetOpKernel {
absl::InfiniteDuration() &&
errors::IsRateLimiterTimeout(FromTensorflowStatus(status))) {
*end_of_sequence = true;
return tensorflow::OkStatus();
return absl::OkStatus();
} else if (sampler_options_.max_samples > 0 &&
absl::IsOutOfRange(FromTensorflowStatus(status))) {
// `max_samples` samples have already been returned by the iterator.
*end_of_sequence = true;
return tensorflow::OkStatus();
return absl::OkStatus();
} else {
return status;
}
Expand Down

0 comments on commit 12cee6a

Please sign in to comment.