diff --git a/python/ray/_private/worker.py b/python/ray/_private/worker.py index 1677843688f9..1c9b5e20b59f 100644 --- a/python/ray/_private/worker.py +++ b/python/ray/_private/worker.py @@ -2313,6 +2313,11 @@ def get( UserWarning, ) + # Record this usage in telemetry + import ray._private.usage.usage_lib as usage_lib + + usage_lib.record_extra_usage_tag(usage_lib.TagKey.RAY_GET_TIMEOUT_ZERO, "True") + worker = global_worker worker.check_connected() diff --git a/src/ray/protobuf/usage.proto b/src/ray/protobuf/usage.proto index 280ddb14a39a..52f397cfbab3 100644 --- a/src/ray/protobuf/usage.proto +++ b/src/ray/protobuf/usage.proto @@ -85,4 +85,8 @@ enum TagKey { // The count(int) of worker crash with exit type 'out-of-memory' since // the cluster started, emitted from GCS WORKER_CRASH_OOM = 303; + // If {true, false} setting of timeout =0 in `ray.get``, i.e. ray.get(..., timeout=0) + // This is to track usage of the buggy behavior that will be fixed. + // See https://github.com/ray-project/ray/issues/28465 for more details. + RAY_GET_TIMEOUT_ZERO = 304; }