enhacne: add lock print

facebookexperimental · Sep 15, 2024 · 9864303 · 9864303
1 parent 53df7e2
commit 9864303
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/robyn_api/robynapi_enpoints.R b/robyn_api/robynapi_enpoints.R
@@ -108,7 +108,9 @@ convert_dates_to_Date <- function(json_data) {
 #* transform InputCollect from API
 transform_InputCollect <- function(InputCollect) {
   promise({
+    sink("Transforming InputCollect Start...")
     lock(mutex)
+    sink("Transforming InputCollect Locking...")
     InputCollect <- jsonlite::fromJSON(InputCollect) %>% convert_dates_to_Date()
 
     # list > tibble
@@ -135,15 +137,19 @@ transform_InputCollect <- function(InputCollect) {
 
     # Add class name which is used as a checker in Robyn
     class(InputCollect) <- c("robyn_inputs", "list")
+    sink("Transforming InputCollect UnLocking...")
     unlock(mutex)
+    sink("Transforming InputCollect Complete...")
     return(InputCollect)
   })
 }
 
 #* transform OutputCollect from API
 transform_OutputCollect <- function(OutputCollect, select_model = FALSE) {
   promise({
+    sink("Transforming OutputCollect Start...")
     lock(mutex)
+    sink("Transforming OutputCollect Locking...")
     OutputCollect <- jsonlite::fromJSON(OutputCollect)
     # Add class name which is used as a checker in Robyn
     class(OutputCollect) <- c("robyn_outputs", "list")
@@ -178,7 +184,9 @@ transform_OutputCollect <- function(OutputCollect, select_model = FALSE) {
           as_tibble() %>%
           mutate(across(where(is.character), as.factor))
     }
+    sink("Transforming OutputCollect UnLocking...")
     unlock(mutex)
+    sink("Transforming OutputCollect Complete...")
     return(OutputCollect)
   })