From 6711d31eb8c428740f938a79a11093fe9b14d62d Mon Sep 17 00:00:00 2001 From: Dmitriy Selivanov Date: Wed, 30 Nov 2022 09:22:39 +0800 Subject: [PATCH] related to warnings #335, see also HenrikBengtsson/future#218 --- R/mc_queue.R | 6 ------ 1 file changed, 6 deletions(-) diff --git a/R/mc_queue.R b/R/mc_queue.R index 2e51bb3..9243ee1 100644 --- a/R/mc_queue.R +++ b/R/mc_queue.R @@ -34,12 +34,6 @@ mc_queue = function(x, finished_jobs = parallel::mccollect(jobs = jobs_in_progress, wait = FALSE) finished_jobs_ids = names(finished_jobs) - - if(length(finished_jobs_ids) > 0) { - # will signal the job as terminating - parallel::mccollect(jobs = jobs_in_progress[finished_jobs_ids], wait = FALSE) - } - for(finished_job_id in finished_jobs_ids) { result[[finished_job_id]] = finished_jobs[[finished_job_id]]