actor_aggregation: removed timeout for parallel processing, requires fix in elasticizer (cannot recycle the same connection)

6 years ago · 54a70c47a0
parent 58fce4d560
commit 54a70c47a0
1 changed files with 0 additions and 1 deletions
--- 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,