From 54a70c47a0a24c74b866e4fc0ad5d7e7cfc266d9 Mon Sep 17 00:00:00 2001 From: Erik de Vries Date: Sun, 12 May 2019 13:13:21 +0200 Subject: [PATCH] actor_aggregation: removed timeout for parallel processing, requires fix in elasticizer (cannot recycle the same connection) --- R/actor_aggregation.R | 1 - 1 file changed, 1 deletion(-) diff --git a/R/actor_aggregation.R b/R/actor_aggregation.R index 93070a0..cdea013 100644 --- a/R/actor_aggregation.R +++ b/R/actor_aggregation.R @@ -64,7 +64,6 @@ actor_aggregation <- function(row, actors, es_pwd, localhost, default_operator = } else { query <- paste0('computerCodes.actors:(',paste(actorids, collapse = ' '),') && publication_date:[',actor$`_source.startDate`,' TO ',actor$`_source.endDate`,']') } - Sys.sleep(runif(1,0.1,0.3)) out <- elasticizer(query_string(paste0('country:',actor$`_source.country`,' && ',query), fields = c('computerCodes.actorsDetail', 'doctype', 'publication_date'), default_operator = default_operator), localhost = localhost,