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()