From eca96463e8ec7782967575356f176278efc24b0f Mon Sep 17 00:00:00 2001 From: Stephen von Takach Date: Wed, 11 Feb 2026 09:51:58 +1100 Subject: [PATCH 1/4] chore(subscriptions): test slow down --- src/placeos-driver/subscriptions.cr | 1 + 1 file changed, 1 insertion(+) diff --git a/src/placeos-driver/subscriptions.cr b/src/placeos-driver/subscriptions.cr index 6ab85765..7d6df06d 100644 --- a/src/placeos-driver/subscriptions.cr +++ b/src/placeos-driver/subscriptions.cr @@ -161,6 +161,7 @@ class PlaceOS::Driver else redis.unsubscribe [chan] end + sleep 1.milliseconds rescue error Log.fatal(exception: error) { "redis subscription failed... some components may not function correctly" } redis.close From c874a77395b2e31df44ddb2beb429254c3a39537 Mon Sep 17 00:00:00 2001 From: Stephen von Takach Date: Wed, 11 Feb 2026 12:13:08 +1100 Subject: [PATCH 2/4] tweak timings in subscriptions --- src/placeos-driver/subscriptions.cr | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/placeos-driver/subscriptions.cr b/src/placeos-driver/subscriptions.cr index 7d6df06d..c45f2940 100644 --- a/src/placeos-driver/subscriptions.cr +++ b/src/placeos-driver/subscriptions.cr @@ -181,7 +181,7 @@ class PlaceOS::Driver instance = monitor_count wait.close loop do - sleep 1.second + sleep 5.seconds break if instance != monitor_count subscription_channel.send({true, SYSTEM_ORDER_UPDATE}) end @@ -289,7 +289,7 @@ class PlaceOS::Driver @redis : Redis? = nil protected def self.new_clustered_redis - Redis::Client.boot(ENV["REDIS_URL"]? || "redis://localhost:6379", reconnect: false) + Redis::Client.boot(ENV["REDIS_URL"]? || "redis://localhost:6379", reconnect: false, command_timeout: 30.seconds) end private def redis_cluster From 0eec6176c67b8cff59412b67b4ba67d2b5512701 Mon Sep 17 00:00:00 2001 From: Stephen von Takach Date: Wed, 11 Feb 2026 13:26:05 +1100 Subject: [PATCH 3/4] chore: tweak timeouts --- src/placeos-driver/subscriptions.cr | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/placeos-driver/subscriptions.cr b/src/placeos-driver/subscriptions.cr index c45f2940..08e7ab69 100644 --- a/src/placeos-driver/subscriptions.cr +++ b/src/placeos-driver/subscriptions.cr @@ -161,7 +161,6 @@ class PlaceOS::Driver else redis.unsubscribe [chan] end - sleep 1.milliseconds rescue error Log.fatal(exception: error) { "redis subscription failed... some components may not function correctly" } redis.close @@ -181,7 +180,7 @@ class PlaceOS::Driver instance = monitor_count wait.close loop do - sleep 5.seconds + sleep 3.seconds break if instance != monitor_count subscription_channel.send({true, SYSTEM_ORDER_UPDATE}) end @@ -289,7 +288,7 @@ class PlaceOS::Driver @redis : Redis? = nil protected def self.new_clustered_redis - Redis::Client.boot(ENV["REDIS_URL"]? || "redis://localhost:6379", reconnect: false, command_timeout: 30.seconds) + Redis::Client.boot(ENV["REDIS_URL"]? || "redis://localhost:6379", reconnect: false, command_timeout: 10.seconds) end private def redis_cluster From 9c20f23f9e29042b6dc51d5e101efb7b71b7aa60 Mon Sep 17 00:00:00 2001 From: Stephen von Takach Date: Wed, 11 Feb 2026 13:34:40 +1100 Subject: [PATCH 4/4] chore(shard.yml): bump deps --- shard.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/shard.yml b/shard.yml index ee8349b4..f37bb46e 100644 --- a/shard.yml +++ b/shard.yml @@ -1,5 +1,5 @@ name: placeos-driver -version: 7.17.5 +version: 7.17.6 dependencies: action-controller: