athena-client - npm Package Compare versions

Comparing version 2.4.0 to 2.5.0

build/lib/client.d.ts

@@ -28,6 +28,6 @@ /// <reference types="node" />
     execute<T>(query: string, callback: (err?: Error, result?: AthenaExecutionResult<T>) => void): void;
-    private _execute(query, csvTransform, config);
-    private canStartQuery();
-    private startQuery();
-    private endQuery();
+    private _execute;
+    private canStartQuery;
+    private startQuery;
+    private endQuery;
 }

build/lib/request.d.ts

@@ -11,2 +11,3 @@ /// <reference types="node" />
     encryptionKmsKey?: string;
+    workGroup?: string;
 }
@@ -13,0 +14,0 @@ export declare class AthenaRequest {

build/lib/request.js

@@ -24,2 +24,3 @@ "use strict";
                 },
+                WorkGroup: config.workGroup || 'primary',
             };
@@ -26,0 +27,0 @@ const loopFunc = () => {

package.json

 {
   "name": "athena-client",
-  "version": "2.4.0",
+  "version": "2.5.0",
   "description": "a nodejs simple aws athena client",
@@ -64,2 +64,2 @@ "homepage": "https://github.com/KoteiIto/node-athena",
   }
-}
+}

README.md

@@ -91,4 +91,4 @@ [![Build Status](https://travis-ci.org/KoteiIto/node-athena.svg?branch=master)](https://travis-ci.org/KoteiIto/node-athena)
 | concurrentExecMax | 5 | DEPRECATED. Use `athena.setConcurrentExecMax()` instead |
+| workGroup | 'primary' | Optional. The name of the workgroup within which the query executes
 
-
 #### `awsConfig` object properties
@@ -95,0 +95,0 @@ | Property  | Default   | Description |

src/lib/client.ts

@@ -167,3 +167,3 @@ import { Athena } from 'aws-sdk'
       // Wait for timeout or query success
-      while (!isTimeout && !await this.request.checkQuery(queryId, config)) {
+      while (!isTimeout && !(await this.request.checkQuery(queryId, config))) {
         await util.sleep(config.pollingInterval || defaultPollingInterval)
@@ -170,0 +170,0 @@ }

src/lib/request.ts

@@ -13,2 +13,3 @@ import { Athena, AWSError } from 'aws-sdk'
   encryptionKmsKey?: string
+  workGroup?: string
 }
@@ -34,2 +35,3 @@
   QueryExecutionContext: QueryExecutionContextParam
+  WorkGroup: string
 }
@@ -67,2 +69,3 @@
         },
+        WorkGroup: config.workGroup || 'primary',
       }
@@ -69,0 +72,0 @@ const loopFunc = () => {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Lines of code

2199

increased by0.41%

Worsened metrics

Total package byte prevSize

124057

decreased by-0.45%

No dependency changes