From 1239e3c781610d7fd3a2c37c6ddb09ad491f3602 Mon Sep 17 00:00:00 2001
From: be-marc <marcbecker@posteo.de>
Date: Sat, 10 Feb 2024 11:37:51 +0100
Subject: [PATCH] fix: stop worker start when config is too large#

---
 R/Rush.R | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/R/Rush.R b/R/Rush.R
index b93afe5..0c1dd68 100644
--- a/R/Rush.R
+++ b/R/Rush.R
@@ -1366,6 +1366,8 @@ Rush = R6::R6Class("Rush",
       dots = list(...)
       r = self$connector
 
+      lg$debug("Pushing worker config to Redis")
+
       # find globals
       if (!is.null(globals)) {
         global_names = if (!is.null(names(globals))) names(globals) else globals
@@ -1392,7 +1394,15 @@ Rush = R6::R6Class("Rush",
         worker_args = worker_args)
 
       # serialize and push arguments to redis
-      r$command(list("SET", private$.get_key("start_args"), redux::object_to_bin(start_args)))
+      bin_start_args = redux::object_to_bin(start_args)
+
+      if (object.size(bin_start_args) > 5369e5) {
+        stop("Worker configuration is larger than 512 MiB. Redis does not support values larger than 512 MiB.")
+      }
+
+      lg$debug("Serializing worker configuration to %s", format(object.size(bin_start_args)))
+
+      r$command(list("SET", private$.get_key("start_args"), bin_start_args))
     },
 
     # fetch tasks