File tree Expand file tree Collapse file tree 1 file changed +5
-6
lines changed
third_party/xla/xla/pjrt/cpu Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -77,20 +77,19 @@ void CpuTrackedDeviceEventPromise::SetReady() {
77
77
}
78
78
79
79
PjRtFuture<> CpuTrackedDeviceEvent::GetReadyFuture () {
80
- PjRtFuture<>::Promise promise = PjRtFuture<>::CreatePromise ();
81
- event_.AndThen ([promise, event = event_]() mutable {
80
+ auto [ promise, future] = PjRtFuture<>::MakePromise ();
81
+ event_.AndThen ([promise = std::move (promise) , event = event_]() mutable {
82
82
if (auto * error = event.GetErrorIfPresent ()) {
83
83
promise.Set (*error);
84
84
} else {
85
85
promise.Set ();
86
86
}
87
87
});
88
88
89
- return PjRtFuture<> (
90
- promise ,
89
+ return PjRtFutureHelpers::WithProfiling (
90
+ std::move (future) ,
91
91
/* on_block_start=*/
92
- [ready_event = FormRef (promise.async_value ()),
93
- callee_method = callee_method_, callee_type = callee_type_]() {
92
+ [callee_method = callee_method_, callee_type = callee_type_]() {
94
93
tsl::profiler::TraceMeProducer traceme (
95
94
[&] { return absl::StrCat (callee_type, " ::" , callee_method); });
96
95
return PjRtFutureHelpers::ProfilingKeys ({traceme.GetContextId ()});
You can’t perform that action at this time.
0 commit comments