mirror of
https://github.com/vale981/ray
synced 2025-03-06 02:21:39 -05:00
to 1.5.0rc0
This commit is contained in:
Jiao Dong
parent
06d8b5bc4f
commit
c3252b7f53
21 changed files with 35 additions and 35 deletions
|
|
@ -7,7 +7,7 @@ set -x
|
|||
|
||||
GPU=""
|
||||
BASE_IMAGE="ubuntu:focal"
|
||||
WHEEL_URL="https://s3-us-west-2.amazonaws.com/ray-wheels/latest/ray-1.5.0-cp37-cp37m-manylinux2014_x86_64.whl"
|
||||
WHEEL_URL="https://s3-us-west-2.amazonaws.com/ray-wheels/latest/ray-1.5.0rc0-cp37-cp37m-manylinux2014_x86_64.whl"
|
||||
PYTHON_VERSION="3.7.7"
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -5,7 +5,7 @@
|
|||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
<packaging>pom</packaging>
|
||||
<name>Ray Project Parent POM</name>
|
||||
<description>An open source framework that provides a simple, universal API for building distributed applications.
|
||||
|
|
@ -63,8 +63,8 @@
|
|||
<properties>
|
||||
<java.version>1.8</java.version>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
<projetct.version>1.5.0</projetct.version>
|
||||
<projetct.version>1.5.0</projetct.version>
|
||||
<projetct.version>1.5.0rc0</projetct.version>
|
||||
<projetct.version>1.5.0rc0</projetct.version>
|
||||
</properties>
|
||||
|
||||
<dependencyManagement>
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-superpom</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -72,7 +72,7 @@ del _configure_system
|
|||
|
||||
# Replaced with the current commit when building the wheels.
|
||||
__commit__ = "{{RAY_COMMIT_SHA}}"
|
||||
__version__ = "1.5.0"
|
||||
__version__ = "1.5.0rc0"
|
||||
|
||||
import ray._raylet # noqa: E402
|
||||
|
||||
|
|
|
|||
|
|
@ -174,7 +174,7 @@ CoreWorkerProcess::CoreWorkerProcess(const CoreWorkerOptions &options)
|
|||
RAY_LOG(DEBUG) << "Stats setup in core worker.";
|
||||
// Initialize stats in core worker global tags.
|
||||
const ray::stats::TagsType global_tags = {{ray::stats::ComponentKey, "core_worker"},
|
||||
{ray::stats::VersionKey, "1.5.0"}};
|
||||
{ray::stats::VersionKey, "1.5.0rc0"}};
|
||||
|
||||
// NOTE(lingxuan.zlx): We assume RayConfig is initialized before it's used.
|
||||
// RayConfig is generated in Java_io_ray_runtime_RayNativeRuntime_nativeInitialize
|
||||
|
|
@ -2935,15 +2935,16 @@ void CoreWorker::HandleExit(const rpc::ExitRequest &request, rpc::ExitReply *rep
|
|||
// any object pinning RPCs in flight.
|
||||
bool is_idle = !own_objects && pins_in_flight == 0;
|
||||
reply->set_success(is_idle);
|
||||
send_reply_callback(Status::OK(),
|
||||
[this, is_idle]() {
|
||||
// If the worker is idle, we exit.
|
||||
if (is_idle) {
|
||||
Exit(rpc::WorkerExitType::IDLE_EXIT);
|
||||
}
|
||||
},
|
||||
// We need to kill it regardless if the RPC failed.
|
||||
[this]() { Exit(rpc::WorkerExitType::INTENDED_EXIT); });
|
||||
send_reply_callback(
|
||||
Status::OK(),
|
||||
[this, is_idle]() {
|
||||
// If the worker is idle, we exit.
|
||||
if (is_idle) {
|
||||
Exit(rpc::WorkerExitType::IDLE_EXIT);
|
||||
}
|
||||
},
|
||||
// We need to kill it regardless if the RPC failed.
|
||||
[this]() { Exit(rpc::WorkerExitType::INTENDED_EXIT); });
|
||||
}
|
||||
|
||||
void CoreWorker::YieldCurrentFiber(FiberEvent &event) {
|
||||
|
|
|
|||
|
|
@ -77,13 +77,12 @@ int main(int argc, char *argv[]) {
|
|||
storage->InternalConfigTable().Put(ray::UniqueID::Nil(), config, on_done));
|
||||
boost::asio::io_service::work work(service);
|
||||
service.run();
|
||||
})
|
||||
.detach();
|
||||
}).detach();
|
||||
promise->get_future().get();
|
||||
|
||||
const ray::stats::TagsType global_tags = {
|
||||
{ray::stats::ComponentKey, "gcs_server"},
|
||||
{ray::stats::VersionKey, "1.5.0"},
|
||||
{ray::stats::VersionKey, "1.5.0rc0"},
|
||||
{ray::stats::NodeAddressKey, node_ip_address}};
|
||||
ray::stats::Init(global_tags, metrics_agent_port);
|
||||
|
||||
|
|
|
|||
|
|
@ -240,7 +240,7 @@ int main(int argc, char *argv[]) {
|
|||
// Initialize stats.
|
||||
const ray::stats::TagsType global_tags = {
|
||||
{ray::stats::ComponentKey, "raylet"},
|
||||
{ray::stats::VersionKey, "1.5.0"},
|
||||
{ray::stats::VersionKey, "1.5.0rc0"},
|
||||
{ray::stats::NodeAddressKey, node_ip_address}};
|
||||
ray::stats::Init(global_tags, metrics_agent_port);
|
||||
|
||||
|
|
|
|||
|
|
@ -7,7 +7,7 @@
|
|||
<modelVersion>4.0.0</modelVersion>
|
||||
<groupId>io.ray</groupId>
|
||||
<artifactId>ray-streaming</artifactId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
<packaging>pom</packaging>
|
||||
<name>Ray Project Streaming Parent POM</name>
|
||||
<description>A streaming framework built on ray</description>
|
||||
|
|
@ -63,7 +63,7 @@
|
|||
<properties>
|
||||
<java.version>1.8</java.version>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
<projetct.version>1.5.0</projetct.version>
|
||||
<projetct.version>1.5.0rc0</projetct.version>
|
||||
<mockito.version>1.10.19</mockito.version>
|
||||
<fst.version>2.57</fst.version>
|
||||
</properties>
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<artifactId>ray-streaming</artifactId>
|
||||
<groupId>io.ray</groupId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<artifactId>ray-streaming</artifactId>
|
||||
<groupId>io.ray</groupId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<artifactId>ray-streaming</artifactId>
|
||||
<groupId>io.ray</groupId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<artifactId>ray-streaming</artifactId>
|
||||
<groupId>io.ray</groupId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<artifactId>ray-streaming</artifactId>
|
||||
<groupId>io.ray</groupId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@
|
|||
<parent>
|
||||
<artifactId>ray-streaming</artifactId>
|
||||
<groupId>io.ray</groupId>
|
||||
<version>1.5.0</version>
|
||||
<version>1.5.0rc0</version>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue