Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
5d630bd
Bump markdown in /ci/official/requirements_updater/numpy1_requirements
dependabot[bot] Mar 10, 2026
e923cf4
fix segfault by adding initialize for deletion
hphng Aug 29, 2026
5287881
fix the join() function to not waiting when start = false|none
hphng Aug 30, 2026
b08bc3d
add testcase when worker or dispatcher start failed combine with join…
hphng Aug 30, 2026
38f75f0
Merge branch 'master' of https://github.com/hphng/tensorflow into fix…
hphng Aug 30, 2026
f1e8404
ci: trigger rebuild
hphng Aug 31, 2026
0fae1d1
revert join function back to void
hphng Sep 1, 2026
9ddd501
[XLA:GPU] Rename collective_kernel_api to multi_gpu_barrier.
PatriosTheGreat Sep 1, 2026
e26cbf5
Disable experimental GEMM fusion v2 in HoistFusedBitcastsReshapeTest.
vwbaker Sep 1, 2026
e3b7ac8
[XLA:GPU] Support duplicating cheap operands in cuDNN conv fusion.
derdrdirk Sep 1, 2026
91fb2c3
Skip fusion computations in HloComputationDeduplicator.
akuegel Sep 1, 2026
b07caa3
Automated Code Change
tensorflower-gardener Sep 1, 2026
0de11b4
Update TritonGemmFusionTest to be parametrized and test GemmFusionV1 …
vwbaker Sep 1, 2026
731ee0d
Merge pull request #126442 from hphng:fix-data-service-server-lib-crash
tensorflower-gardener Sep 1, 2026
93066fa
Propagate constraints across kCall boundaries in ConstraintPropagator.
bhatuzdaname Sep 1, 2026
674373b
Merge pull request #111739 from tensorflow:dependabot/pip/ci/official…
tensorflower-gardener Sep 1, 2026
26a3cc9
Get TAP ready for Gemm Fusion V2 flag flip - explicitly set experimen…
vwbaker Sep 1, 2026
2d7a460
Leverage input_devices_for_output_map in RemapArrays for PJRT IFRT.
junwhanahn Sep 1, 2026
7bd3888
Replace TF_ASSERT_OK_AND_ASSIGN with ASSERT_OK_AND_ASSIGN in triton_f…
vwbaker Sep 1, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -248,9 +248,9 @@ libclang==18.1.1 \
lit==17.0.6 \
--hash=sha256:dfa9af9b55fc4509a56be7bf2346f079d7f4a242d583b9f2e0b078fd0abae31b
# via -r ci/official/requirements_updater/requirements.in
markdown==3.8 \
--hash=sha256:794a929b79c5af141ef5ab0f2f642d0f7b1872981250230e72682346f7cc90dc \
--hash=sha256:7df81e63f0df5c4b24b7d156eb81e4690595239b7d70937d0409f1b0de319c6f
markdown==3.8.1 \
--hash=sha256:46cc0c0f1e5211ab2e9d453582f0b28a1bfaf058a9f7d5c50386b99b588d8811 \
--hash=sha256:a2e2f01cead4828ee74ecca9623045f62216aef2212a7685d6eb9163f590b8c1
# via tb-nightly
markdown-it-py==3.0.0 \
--hash=sha256:355216845c60bd96232cd8d8c40e8f9765cc86f46880e43a8fd22dc1a1a8cab1 \
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -248,9 +248,9 @@ libclang==18.1.1 \
lit==17.0.6 \
--hash=sha256:dfa9af9b55fc4509a56be7bf2346f079d7f4a242d583b9f2e0b078fd0abae31b
# via -r ci/official/requirements_updater/requirements.in
markdown==3.8 \
--hash=sha256:794a929b79c5af141ef5ab0f2f642d0f7b1872981250230e72682346f7cc90dc \
--hash=sha256:7df81e63f0df5c4b24b7d156eb81e4690595239b7d70937d0409f1b0de319c6f
markdown==3.8.1 \
--hash=sha256:46cc0c0f1e5211ab2e9d453582f0b28a1bfaf058a9f7d5c50386b99b588d8811 \
--hash=sha256:a2e2f01cead4828ee74ecca9623045f62216aef2212a7685d6eb9163f590b8c1
# via tb-nightly
markdown-it-py==3.0.0 \
--hash=sha256:355216845c60bd96232cd8d8c40e8f9765cc86f46880e43a8fd22dc1a1a8cab1 \
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -248,9 +248,9 @@ libclang==18.1.1 \
lit==17.0.6 \
--hash=sha256:dfa9af9b55fc4509a56be7bf2346f079d7f4a242d583b9f2e0b078fd0abae31b
# via -r ci/official/requirements_updater/requirements.in
markdown==3.8 \
--hash=sha256:794a929b79c5af141ef5ab0f2f642d0f7b1872981250230e72682346f7cc90dc \
--hash=sha256:7df81e63f0df5c4b24b7d156eb81e4690595239b7d70937d0409f1b0de319c6f
markdown==3.8.1 \
--hash=sha256:46cc0c0f1e5211ab2e9d453582f0b28a1bfaf058a9f7d5c50386b99b588d8811 \
--hash=sha256:a2e2f01cead4828ee74ecca9623045f62216aef2212a7685d6eb9163f590b8c1
# via tb-nightly
markdown-it-py==3.0.0 \
--hash=sha256:355216845c60bd96232cd8d8c40e8f9765cc86f46880e43a8fd22dc1a1a8cab1 \
Expand Down
7 changes: 6 additions & 1 deletion tensorflow/core/data/service/server_lib.cc
Original file line number Diff line number Diff line change
Expand Up @@ -103,7 +103,12 @@ void GrpcDataServerBase::Stop() {
stopped_ = true;
}

void GrpcDataServerBase::Join() { server_->Wait(); }
void GrpcDataServerBase::Join() {
if (!server_) {
return;
}
server_->Wait();
}

int GrpcDataServerBase::BoundPort() { return bound_port(); }

Expand Down
4 changes: 2 additions & 2 deletions tensorflow/core/data/service/server_lib.h
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ class DispatchGrpcDataServer : public GrpcDataServerBase {
private:
const experimental::DispatcherConfig config_;
// Owned. We use a raw pointer because GrpcDispatcherImpl is forward-declared.
GrpcDispatcherImpl* service_;
GrpcDispatcherImpl* service_ = nullptr;
};

// A wrapper for `SnapshotTaskProgress` for use with pybind.
Expand Down Expand Up @@ -170,7 +170,7 @@ class WorkerGrpcDataServer : public GrpcDataServerBase {

const experimental::WorkerConfig config_;
// Owned. We use a raw pointer because GrpcWorkerImpl is forward-declared.
GrpcWorkerImpl* service_;
GrpcWorkerImpl* service_ = nullptr;
std::shared_ptr<DataTransferServer> transfer_server_;
};

Expand Down
10 changes: 8 additions & 2 deletions tensorflow/core/kernels/linalg/BUILD
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,10 @@ tf_kernel_library(
tf_kernel_library(
name = "matrix_diag_op",
prefix = "matrix_diag_op",
deps = LINALG_DEPS,
deps = LINALG_DEPS + [
"@com_google_absl//absl/status",
"@com_google_absl//absl/strings",
],
)

tf_kernel_library(
Expand Down Expand Up @@ -183,7 +186,10 @@ tf_kernel_library(
tf_kernel_library(
name = "self_adjoint_eig_op",
prefix = "self_adjoint_eig_op",
deps = LINALG_DEPS + ["//tensorflow/core:lib_internal"],
deps = LINALG_DEPS + [
"//tensorflow/core:lib_internal",
"@com_google_absl//absl/status",
],
)

tf_kernel_library(
Expand Down
2 changes: 2 additions & 0 deletions tensorflow/core/kernels/linalg/lu_op.cc
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,8 @@ limitations under the License.
#include <limits>

#include "absl/container/inlined_vector.h"
#include "absl/status/status.h"
#include "absl/strings/str_cat.h"
#include "Eigen/Core" // from @eigen_archive
#include "Eigen/LU" // from @eigen_archive
#include "tensorflow/core/framework/kernel_def_builder.h"
Expand Down
11 changes: 7 additions & 4 deletions tensorflow/core/kernels/linalg/matrix_diag_op.cc
Original file line number Diff line number Diff line change
Expand Up @@ -14,17 +14,19 @@ limitations under the License.
==============================================================================*/

// See docs in ../ops/array_ops.cc.
#include <string>
#include <tuple>
#include <utility>

#include "absl/status/status.h"
#include "absl/strings/str_cat.h"
#define EIGEN_USE_THREADS

#if GOOGLE_CUDA || TENSORFLOW_USE_ROCM
#define EIGEN_USE_GPU
#endif // GOOGLE_CUDA || TENSORFLOW_USE_ROCM

#include "tensorflow/core/kernels/linalg/matrix_diag_op.h"

#include <algorithm>
#include <memory>
#include <vector>

#include "unsupported/Eigen/CXX11/Tensor" // from @eigen_archive
#include "tensorflow/core/framework/op_kernel.h"
Expand All @@ -33,6 +35,7 @@ limitations under the License.
#include "tensorflow/core/framework/tensor_shape.h"
#include "tensorflow/core/framework/tensor_types.h"
#include "tensorflow/core/framework/types.h"
#include "tensorflow/core/kernels/linalg/matrix_diag_op.h"
#include "tensorflow/core/lib/core/errors.h"
#include "tensorflow/core/lib/core/threadpool.h"
#include "tensorflow/core/platform/logging.h"
Expand Down
1 change: 1 addition & 0 deletions tensorflow/core/kernels/linalg/self_adjoint_eig_op.cc
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ limitations under the License.

#include <cstdint>

#include "absl/status/status.h"
#include "Eigen/Core" // from @eigen_archive
#include "Eigen/Eigenvalues" // from @eigen_archive
#include "tensorflow/core/framework/kernel_def_builder.h"
Expand Down
22 changes: 22 additions & 0 deletions tensorflow/python/data/experimental/service/server_lib_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,28 @@ def testJoinWorker(self):
worker.stop()
worker.join()

def testJoinDispatcherWithoutStart(self):
dispatcher = server_lib.DispatchServer(start=False)
dispatcher.join()

def testJoinWorkerWithoutStart(self):
dispatcher = server_lib.DispatchServer()
worker = server_lib.WorkerServer(
server_lib.WorkerConfig(dispatcher._address), start=False
)
worker.join()

def testDispatcherDestroyedWithoutStart(self):
dispatcher = server_lib.DispatchServer(start=False)
del dispatcher

def testWorkerDestroyedWithoutStart(self):
dispatcher = server_lib.DispatchServer()
worker = server_lib.WorkerServer(
server_lib.WorkerConfig(dispatcher._address), start=False
)
del worker

def testDispatcherNumWorkers(self):
dispatcher = server_lib.DispatchServer()
self.assertEqual(0, dispatcher._num_workers())
Expand Down
5 changes: 3 additions & 2 deletions third_party/xla/xla/backends/gpu/codegen/triton/BUILD
Original file line number Diff line number Diff line change
Expand Up @@ -366,7 +366,6 @@ xla_test(
"//xla/backends/gpu/tests:gpu_pjrt_codegen_test",
"//xla/backends/gpu/transforms:convert_triton_gemm_config",
"//xla/codegen/xtile:block_level_parameters",
"//xla/hlo/analysis:symbolic_map",
"//xla/hlo/ir:hlo",
"//xla/hlo/testlib:filecheck",
"//xla/hlo/testlib:pattern_matcher_gmock",
Expand All @@ -379,8 +378,10 @@ xla_test(
"//xla/service/gpu:target_constants",
"//xla/stream_executor:device_description",
"//xla/stream_executor/cuda:cuda_compute_capability",
"//xla/tests:hlo_pjrt_interpreter_reference_mixin",
"//xla/tests:hlo_interpreter_reference_mixin",
"//xla/tests:xla_internal_test_main", # fixdeps: keep
"//xla/tsl/lib/core:status_test_util",
"//xla/tsl/platform:env",
"//xla/tsl/platform:errors",
"//xla/tsl/platform:test",
"@com_google_absl//absl/log:check",
Expand Down
Loading
Loading