Skip to content

Commit

Permalink
Automated Code Change
Browse files Browse the repository at this point in the history
PiperOrigin-RevId: 624782782
  • Loading branch information
tensorflower-gardener committed Apr 15, 2024
1 parent 9b6cae6 commit 2123389
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions tensorflow/distribute/experimental/rpc/kernels/rpc_ops.cc
Expand Up @@ -206,7 +206,7 @@ class FunctionRegistry {
return tensorflow::errors::InvalidArgument(
absl::StrCat(method, " is already registered."));
}
return OkStatus();
return absl::OkStatus();
}

tensorflow::Status LookUp(const std::string& method,
Expand All @@ -219,7 +219,7 @@ class FunctionRegistry {
}

*output = it->second;
return OkStatus();
return absl::OkStatus();
}

const gtl::FlatMap<std::string, FunctionMetadata>& List() const {
Expand Down Expand Up @@ -532,7 +532,7 @@ void RpcServerOp::Compute(OpKernelContext* ctx) {
// Create resource
auto creator = [address](RpcServer** server) {
*server = new RpcServer(address);
return OkStatus();
return absl::OkStatus();
};
core::RefCountPtr<RpcServer> server;
OP_REQUIRES_OK(ctx, LookupOrCreateResource<RpcServer>(ctx, resource_handle,
Expand Down Expand Up @@ -573,7 +573,7 @@ void RpcClientOp::ComputeAsync(OpKernelContext* ctx, DoneCallback done) {
// Create resource
auto creator = [&address, &resource_name, timeout_in_ms](RpcClient** client) {
*client = new RpcClient(address, resource_name, timeout_in_ms);
return OkStatus();
return absl::OkStatus();
};

core::RefCountPtr<RpcClient> client;
Expand Down Expand Up @@ -624,7 +624,7 @@ void RpcServerStartOp::Compute(OpKernelContext* ctx) {
OP_REQUIRES_OK(ctx, LookupResource(ctx, HandleFromInput(ctx, 0), &server));

server->StartServer();
ctx->SetStatus(OkStatus());
ctx->SetStatus(absl::OkStatus());
}

RpcServerRegisterOp::RpcServerRegisterOp(OpKernelConstruction* ctx)
Expand Down Expand Up @@ -735,7 +735,7 @@ void RpcCallOp::Compute(OpKernelContext* ctx) {
// Create resource
auto creator = [](RpcFutureResource** resource) {
*resource = new RpcFutureResource();
return OkStatus();
return absl::OkStatus();
};
core::RefCountPtr<RpcFutureResource> future_resource;
OP_REQUIRES_OK(ctx, LookupOrCreateResource<RpcFutureResource>(
Expand Down

0 comments on commit 2123389

Please sign in to comment.