Skip to content

Commit

Permalink
[Pubsub] increase subscriber timeout (ray-project#22394)
Browse files Browse the repository at this point in the history
As mentioned in ray-project#22161 (comment), increase subscriber timeout to avoid subscriber state being deleted too soon.
  • Loading branch information
mwtian authored Feb 15, 2022
1 parent 9a7979d commit 32035eb
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions src/ray/common/ray_config_def.h
Original file line number Diff line number Diff line change
Expand Up @@ -454,9 +454,10 @@ RAY_CONFIG(int64_t, max_command_batch_size, 2000)
/// The maximum batch size for OBOD report.
RAY_CONFIG(int64_t, max_object_report_batch_size, 2000)

/// The time where the subscriber connection is timed out in milliseconds.
/// This is for the pubsub module.
RAY_CONFIG(uint64_t, subscriber_timeout_ms, 30000)
/// For Ray publishers, the minimum time to drop an inactive subscriber connection in ms.
/// In the current implementation, a subscriber might be dead for up to 3x the configured
/// time before it is deleted from the publisher, i.e. deleted in 300s ~ 900s.
RAY_CONFIG(uint64_t, subscriber_timeout_ms, 300 * 1000)

// This is the minimum time an actor will remain in the actor table before
// being garbage collected when a job finishes
Expand Down

0 comments on commit 32035eb

Please sign in to comment.