From 22f9e0722d97e4ab34c4408acb01efd6ffd003a0 Mon Sep 17 00:00:00 2001 From: junos Date: Wed, 1 Dec 2021 11:29:22 +0100 Subject: [PATCH] Start preparing the true usernames CSV file. --- src/data/streams/aware_postgresql/container.R | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/data/streams/aware_postgresql/container.R b/src/data/streams/aware_postgresql/container.R index f9fe8774..c453181f 100644 --- a/src/data/streams/aware_postgresql/container.R +++ b/src/data/streams/aware_postgresql/container.R @@ -121,7 +121,7 @@ pull_participants_ids <- function(stream_parameters, usernames, participants_con filter(username %in% usernames) %>% select(username, id) - message(paste0("Executing the following query to get the participant's id: \n", sql_render(query_participant_id))) + message(paste0("Executing the following query to get participants' IDs: \n", sql_render(query_participant_id))) participant_data <- query_participant_id %>% collect() @@ -149,7 +149,13 @@ pull_participants_device_ids <- function(stream_parameters, participants_ids, de group_by(participant_id) %>% distinct(device_id, .keep_all = FALSE) - message(paste0("Executing the following query to get the distinct device IDs: \n", sql_render(query_device_id))) + message( + paste0( + "Executing the following query to get the distinct device IDs: \n", + sql_render(query_device_id), + "\n NOTE: This might take a long time." + ) + ) device_ids <- query_device_id %>% collect()