Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Expand supported RayError exceptions #221

Merged
merged 32 commits into from
Nov 9, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
32 commits
Select commit Hold shift + click to select a range
dae17ff
Add exception `WorkerCrashedError`
omus Oct 18, 2023
72d25e3
Add exception `LocalRayletDiedError`
omus Oct 18, 2023
b60c40f
Add exception `TaskCancelledError`
omus Oct 18, 2023
361be3a
Add exception `ObjectLostError`
omus Oct 18, 2023
9aee78d
Create abstract type `ObjectStoreError`
omus Oct 18, 2023
6802db0
Create abstract type `ObjectFetchTimedOutError`
omus Oct 18, 2023
1d1db46
Create abstract type `OutOfDiskError`
omus Oct 19, 2023
14ebe6b
Refactor code with `ObjectContext`
omus Oct 19, 2023
c64645e
Add exception `NodeDiedError`
omus Oct 19, 2023
e604bb7
Add exception `ReferenceCountingAssertionError`
omus Oct 19, 2023
4a71993
Add exception `ObjectFreedError`
omus Oct 19, 2023
e48bf8f
Add exception `OwnerDiedError`
omus Oct 19, 2023
c3aecda
fixup! Add exception `OwnerDiedError`
omus Oct 25, 2023
41bb076
Add exception `ObjectReconstructionFailedError`
omus Oct 25, 2023
0e45a7d
Add exception `ObjectReconstructionFailedMaxAttemptsExceededError`
omus Oct 25, 2023
f9d1f82
Add exception `ObjectReconstructionFailedLineageEvictedError`
omus Oct 25, 2023
843765f
fixup! Add exception `ObjectReconstructionFailedMaxAttemptsExceededEr…
omus Oct 25, 2023
bc651cc
Add exception `RuntimeEnvSetupError`
omus Oct 25, 2023
3ffa0e2
Reference code this is based upon
omus Nov 3, 2023
2ff71fc
Add exception `TaskPlacementGroupRemoved`
omus Nov 3, 2023
2812a9c
Add exception `ActorPlacementGroupRemoved`
omus Nov 3, 2023
da84d77
Add exception `TaskUnschedulableError`
omus Nov 3, 2023
abd7f5b
Add exception `ActorUnschedulableError`
omus Nov 3, 2023
f3570b4
Order exceptions alphabetically
omus Nov 3, 2023
ad1be2b
Avoid using deserialize_error_info on exception data we have never seen
omus Nov 3, 2023
f02f5bb
Formatting refactoring
omus Nov 3, 2023
59fa4a3
Merge branch 'main' into cv/more-error-codes
omus Nov 3, 2023
2431881
Fix bad merge
omus Nov 3, 2023
cb1c973
Correct max retries value
omus Nov 9, 2023
35cd871
Reference support free issue
omus Nov 9, 2023
eb3f30a
Merge branch 'main' into cv/more-error-codes
omus Nov 9, 2023
6edc777
Set project version to 0.0.4
omus Nov 9, 2023
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
4 changes: 3 additions & 1 deletion Project.toml
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
name = "Ray"
uuid = "3f779ece-f0b6-4c4f-a81a-0cb2add9eb95"
authors = ["Beacon Biosignals, Inc"]
version = "0.0.3"
version = "0.0.4"

[deps]
ArgParse = "c7e460c6-2fb9-53a9-8c5b-16f535851c63"
Expand All @@ -12,6 +12,7 @@ Dates = "ade2ca70-3891-5945-98fb-dc099432e06a"
JSON3 = "0f8b85d8-7281-11e9-16c2-39a750bddbf1"
Logging = "56ddb016-857b-54e1-b83d-db4d58db5568"
LoggingExtras = "e6f89c97-d47a-5376-807f-9c37f3926c36"
MultilineStrings = "1e8d2bf6-9821-4900-9a2f-4d87552df2bd"
Pkg = "44cfe95a-1eb2-52ea-b672-e2afdf69b78f"
Serialization = "9e88b42a-f829-5b0c-bbe9-9e923198166b"
Sockets = "6462fe0b-24de-5631-8697-dd941f90decc"
Expand All @@ -23,6 +24,7 @@ ArgParse = "1"
CxxWrap = "0.14.2"
JSON3 = "1"
LoggingExtras = "1"
MultilineStrings = "0.1.1"
julia = "1.8"
libcxxwrap_julia_jll = "0.11"

Expand Down
12 changes: 10 additions & 2 deletions src/Ray.jl
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ using Dates: Dates, DateFormat, @dateformat_str, now
using JSON3
using Logging
using LoggingExtras
using MultilineStrings
using Pkg
using Serialization: Serialization, AbstractSerializer, Serializer, deserialize,
reset_state, serialize, serialize_type, ser_version, writeheader
Expand All @@ -21,17 +22,24 @@ using Sockets: IPAddr, getipaddr
export start_worker, submit_task, @ray_import, ObjectRef

# exceptions
export RayError, RaySystemError, RayTaskError
export ActorPlacementGroupRemoved, ActorUnschedulableError, LocalRayletDiedError,
NodeDiedError, ObjectFetchTimedOutError, ObjectFreedError, ObjectLostError,
ObjectReconstructionFailedError, ObjectReconstructionFailedLineageEvictedError,
ObjectReconstructionFailedMaxAttemptsExceededError, OutOfDiskError, OwnerDiedError,
RayError, RaySystemError, RayTaskError, ReferenceCountingAssertionError,
RuntimeEnvSetupError, TaskCancelledError, TaskPlacementGroupRemoved,
TaskUnschedulableError, WorkerCrashedError

include(joinpath("ray_julia_jll", "ray_julia_jll.jl"))
using .ray_julia_jll: ray_julia_jll, ray_julia_jll as ray_jll

include("exceptions.jl")
include("constants.jl")
include("function_manager.jl")
include("runtime_env.jl")
include("remote_function.jl")
include("runtime.jl")
include("object_ref.jl")
include("exceptions.jl")
include("ray_serializer.jl")
include("object_store.jl")

Expand Down
2 changes: 2 additions & 0 deletions src/constants.jl
Original file line number Diff line number Diff line change
@@ -0,0 +1,2 @@
# Default `max_retries` option for non-actor tasks. Ray for Python defaults to 3.
const DEFAULT_TASK_MAX_RETRIES = 0
Loading