From 7ab0acad60eaffd553606e77a040955f36904396 Mon Sep 17 00:00:00 2001
From: hrbrmstr <bob@rud.is>
Date: Wed, 4 Mar 2020 03:30:08 -0500
Subject: [PATCH] v2

---
 DESCRIPTION       | 4 ++--
 NEWS.md           | 3 +++
 R/collect-async.R | 6 +++++-
 3 files changed, 10 insertions(+), 3 deletions(-)

diff --git a/DESCRIPTION b/DESCRIPTION
index 6d4d22d..f276228 100644
--- a/DESCRIPTION
+++ b/DESCRIPTION
@@ -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")
   )
diff --git a/NEWS.md b/NEWS.md
index 66d26c6..5863a0d 100644
--- a/NEWS.md
+++ b/NEWS.md
@@ -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
diff --git a/R/collect-async.R b/R/collect-async.R
index fb47097..95077dd 100644
--- a/R/collect-async.R
+++ b/R/collect-async.R
@@ -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,