ray/python/ray
Qing Wang 4cc34588db
[Core] Support ConcurrentGroup part1 (#16795)
* Core change and Java change.

* Fix void call.

* Address comments and fix cases.

* Fix asyncio
2021-08-07 22:41:33 +08:00
..
_private [Dependencies] Fix missing dependency UX (#17420) 2021-08-05 20:18:42 -07:00
autoscaler [Dependencies] Fix missing dependency UX (#17420) 2021-08-05 20:18:42 -07:00
cloudpickle Cloudpickle workaround for false positive cases (#15202) 2021-04-09 02:22:46 -07:00
core Define common data structures with protobuf. (#5121) 2019-07-08 22:41:37 +08:00
data Don't capture child tasks in placement groups by default (#17527) 2021-08-04 16:09:45 -07:00
experimental [Serve] [Dashboard] Initial PR for exporting Serve data to cluster snapshot (#17489) 2021-08-06 15:03:29 -07:00
includes [Core] Support ConcurrentGroup part1 (#16795) 2021-08-07 22:41:33 +08:00
internal [core] Do not spill back tasks blocked on args to blocked nodes (#17550) 2021-08-05 20:43:32 -07:00
ray_operator [k8s] Refactored k8s operator to use kopf for controller logic (#15787) 2021-06-01 12:00:55 -07:00
scripts [client][docs] update docs for new client support in init (#17333) 2021-08-04 05:31:44 +03:00
serve [Serve] Add replica tag to request counter and error counter (#17613) 2021-08-06 15:35:34 -07:00
tests [Core] Support ConcurrentGroup part1 (#16795) 2021-08-07 22:41:33 +08:00
tune [Tune] Update docs for with_parameters (#17441) 2021-08-05 08:48:34 -07:00
util [Serve] [Dashboard] Initial PR for exporting Serve data to cluster snapshot (#17489) 2021-08-06 15:03:29 -07:00
workers [runtime env] [Doc] Runtime env doc and messaging improvements (#17547) 2021-08-04 12:28:42 -07:00
__init__.py Move ray.data out of experimental (#17560) 2021-08-04 13:31:10 -07:00
_raylet.pxd [object store] Assign the object owner in ray.put() (#16833) 2021-07-20 11:06:00 -07:00
_raylet.pyi [Core] Type check ObjectRef (#9856) 2020-08-11 10:38:29 -07:00
_raylet.pyx [Core] Support ConcurrentGroup part1 (#16795) 2021-08-07 22:41:33 +08:00
actor.py [RFC][Usability] Improve general Ray stacktrace including adding Actor repr (#17389) 2021-08-05 17:12:24 -07:00
client_builder.py [client][docs] update docs for new client support in init (#17333) 2021-08-04 05:31:44 +03:00
cluster_utils.py [core] Fixes connect from worker node failed (#16045) 2021-06-11 18:51:46 -07:00
cross_language.py Update PublicAPI annotations #17224 2021-07-20 16:37:53 -07:00
exceptions.py [RFC][Usability] Improve general Ray stacktrace including adding Actor repr (#17389) 2021-08-05 17:12:24 -07:00
external_storage.py Fix flaky test_plasma_unlimited::test_fallback_allocation_failure (#17016) 2021-07-12 20:17:23 -07:00
gcs_utils.py Split heartbeat message (#12535) 2020-12-11 21:19:57 +08:00
job_config.py [Core] [runtime env] Don't delete working_dir from runtime env (#16475) 2021-06-18 10:15:20 -05:00
new_dashboard [Dashboard] New dashboard skeleton (#9099) 2020-07-27 11:34:47 +08:00
nightly-wheels.yaml Bump dev branch to 2.0 to avoid endless version bump toil (#13497) 2021-01-15 17:41:17 -08:00
node.py [Dashboard] Allow Agent HTTP listening port to be specified. (#17392) 2021-08-02 02:09:50 -07:00
profiling.py Disable timeline events collection in Ray by default (#15989) 2021-06-02 18:04:29 -07:00
py.typed Support ray task type checking (#9574) 2020-07-21 19:05:42 -07:00
ray_cluster_perf.py [Core] Adds deprecation decorator and fixes privatization of a few APIs. (#14811) 2021-03-22 10:31:50 -07:00
ray_constants.py Add a warning if the number of queued tasks to an actor exceeds 5k (#17581) 2021-08-05 12:03:48 -07:00
ray_perf.py [release] Move xgboost tune small + microbenchmark release test to new release automation (#15619) 2021-05-08 20:38:39 +01:00
remote_function.py [Runtime Env] Support per task/actor uri override job_config (#17252) 2021-07-22 16:37:43 -07:00
resource_spec.py [autoscaler][kubernetes] Helm chart (#15614) 2021-05-17 16:55:10 -07:00
rllib [rllib] Try moving RLlib to top level dir (#5324) 2019-08-05 23:25:49 -07:00
runtime_context.py [RFC] API stability annotations (#17100) 2021-07-16 17:09:20 -07:00
serialization.py [runtime_env] Gracefully fail tasks when an environment fails to be set up (#17249) 2021-07-28 15:25:02 -05:00
serialization_addons.py [Serialization] Pydantic -> serialization_addons.py and Ray Client support. (#15181) 2021-04-14 15:21:13 -07:00
services.py [Code Cleanup] Switch to use ray.util.get_node_ip_address() (#14741) 2021-03-18 13:10:57 -07:00
setup-dev.py Add ray.data symlink to setup-dev.py (#17624) 2021-08-05 19:51:15 -07:00
state.py [RFC] API stability annotations (#17100) 2021-07-16 17:09:20 -07:00
streaming [Streaming] Streaming data transfer and python integration (#6185) 2019-12-10 20:33:24 +08:00
test_utils.py [Core] [runtime env] Avoid spurious worker startup (#17422) 2021-08-05 15:46:23 -05:00
types.py [data] Fix the ObjectRef type in the dataset docs (#17111) 2021-07-15 09:50:37 -07:00
utils.py [Core] Adds deprecation decorator and fixes privatization of a few APIs. (#14811) 2021-03-22 10:31:50 -07:00
worker.py [core] Skip adding "script directory" to workers' sys.path when in interactive shell (#17556) 2021-08-05 10:05:19 -05:00
worker.pyi [Core] Type check ObjectRef (#9856) 2020-08-11 10:38:29 -07:00