mirror of
https://github.com/vale981/ray
synced 2025-03-04 17:41:43 -05:00
fix
Signed-off-by: Clarence Ng <clarence.wyng@gmail.com>
This commit is contained in:
parent
649b846a8f
commit
a2386c4a8d
3 changed files with 1 additions and 4 deletions
|
@ -162,7 +162,7 @@ class BlockExecStats:
|
|||
# Max memory usage. May be an overestimate since we do not
|
||||
# differentiate from previous tasks on the same worker.
|
||||
self.max_rss_bytes: int = 0
|
||||
|
||||
|
||||
@staticmethod
|
||||
def builder() -> "_BlockExecStatsBuilder":
|
||||
return _BlockExecStatsBuilder()
|
||||
|
|
|
@ -195,8 +195,6 @@ enum ErrorType {
|
|||
ACTOR_UNSCHEDULABLE_ERROR = 19;
|
||||
// We use this error for object fetches that failed due to out of disk.
|
||||
OUT_OF_DISK_ERROR = 20;
|
||||
// We use this error for task or actor failing due to running of of memory.
|
||||
OUT_OF_MEMORY_ERROR = 21;
|
||||
}
|
||||
|
||||
/// The information per ray error type.
|
||||
|
|
|
@ -983,7 +983,6 @@ void WorkerPool::PushWorker(const std::shared_ptr<WorkerInterface> &worker) {
|
|||
int64_t now = get_time_();
|
||||
idle_of_all_languages_.emplace_back(worker, now);
|
||||
idle_of_all_languages_map_[worker] = now;
|
||||
TryKillingIdleWorkers();
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue