Skip to content

Commit 41ff63e

Browse files
Merge pull request #646 from laughingman7743/feature/workgroup-table-metadata
Pass WorkGroup parameter to GetTableMetadata and ListTableMetadata APIs
2 parents f76e1a5 + 60e1a09 commit 41ff63e

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

pyathena/common.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -292,6 +292,8 @@ def _build_list_table_metadata_request(
292292
request.update({"Expression": expression})
293293
if next_token:
294294
request.update({"NextToken": next_token})
295+
if self._work_group:
296+
request.update({"WorkGroup": self._work_group})
295297
return request
296298

297299
def _build_list_databases_request(
@@ -306,6 +308,8 @@ def _build_list_databases_request(
306308
}
307309
if next_token:
308310
request.update({"NextToken": next_token})
311+
if self._work_group:
312+
request.update({"WorkGroup": self._work_group})
309313
return request
310314

311315
def _list_databases(
@@ -359,11 +363,13 @@ def _get_table_metadata(
359363
schema_name: Optional[str] = None,
360364
logging_: bool = True,
361365
) -> AthenaTableMetadata:
362-
request = {
366+
request: Dict[str, Any] = {
363367
"CatalogName": catalog_name if catalog_name else self._catalog_name,
364368
"DatabaseName": schema_name if schema_name else self._schema_name,
365369
"TableName": table_name,
366370
}
371+
if self._work_group:
372+
request.update({"WorkGroup": self._work_group})
367373
try:
368374
response = retry_api_call(
369375
self._connection.client.get_table_metadata,

0 commit comments

Comments
 (0)