3 files changed, 10 insertions(+), 3 deletions(-)

M DESCRIPTION
M NEWS.md
M R/collect-async.R

@@ 1,8 1,8 @@
 Package: awsathena
 Type: Package
 Title: rJava Interface to AWS Athena SDK
-Version: 0.2.0
-Date: 2019-06-14
+Version: 0.3.1
+Date: 2020-03-04
 Authors@R: c(
     person("Bob", "Rudis", role = c("aut", "cre"), email = "bob@rud.is")
   )

@@ 1,3 1,6 @@
+0.3.1
+* `workgroup` is now able to be specified for Athena ops
+
 0.3.0
 * buffer for download is now a parameter
 * added `get_query_results_metadata()` to enable retrieval of col types

@@ 78,8 78,12 @@ collect_async <- function(obj,
   if (!requireNamespace("dbplyr", quietly = TRUE)) {
     stop("dbplyr package required for this function", call. = FALSE)
   } else {
+
+    qry <- dbplyr::sql_render(obj)
+    qry <- as.character(qry)
+
     start_query_execution(
-      query = as.character(dbplyr::sql_render(obj)),
+      query = qry,
       database = database,
       output_location = output_location,
       client_request_token = client_request_token,