We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7b160c7 commit fd97254Copy full SHA for fd97254
1 file changed
sdk/python/feast/infra/offline_stores/redshift_source.py
@@ -206,7 +206,8 @@ def get_table_column_names_and_types(
206
client = aws_utils.get_redshift_data_client(config.offline_store.region)
207
if self.table:
208
try:
209
- table = client.describe_table(
+ paginator = client.get_paginator("describe_table")
210
+ response_iterator = paginator.paginate(
211
ClusterIdentifier=config.offline_store.cluster_id,
212
Database=(
213
self.database
@@ -217,6 +218,7 @@ def get_table_column_names_and_types(
217
218
Table=self.table,
219
Schema=self.schema,
220
)
221
+ table = response_iterator.build_full_result()
222
except ClientError as e:
223
if e.response["Error"]["Code"] == "ValidationException":
224
raise RedshiftCredentialsError() from e
0 commit comments