update to use either .slaveRSOCK or .workRSOCK given changes to paral…

…lel pkg
paciorek · Jun 25, 2021 · 52900bf · 52900bf
1 parent c842259
commit 52900bf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/templates/future-worker-deployment.yaml b/templates/future-worker-deployment.yaml
@@ -33,7 +33,7 @@ spec:
           args:
             - sh
             - -c
-            - "Rscript -e 'setup_kube()' && Rscript --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'parallel:::.slaveRSOCK()' MASTER=future-scheduler PORT={{ .Values.scheduler.RfuturePort }} OUT=/tmp/rworker.log SETUPTIMEOUT=2592000 TIMEOUT=2592000 XDR=TRUE"
+            - "Rscript -e 'setup_kube()' && Rscript --default-packages=datasets,utils,grDevices,graphics,stats,methods -e 'workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()' MASTER=future-scheduler PORT={{ .Values.scheduler.RfuturePort }} OUT=/tmp/rworker.log SETUPTIMEOUT=2592000 TIMEOUT=2592000 XDR=TRUE"
           ports:
             - containerPort: 8789
           resources: