Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
mark-major committed Sep 10, 2024
1 parent aecbe1b commit 5dcddad
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions pyiceberg/catalog/dynamodb.py
Original file line number Diff line number Diff line change
Expand Up @@ -393,7 +393,7 @@ def drop_namespace(self, namespace: Union[str, Identifier]) -> None:
raise NoSuchNamespaceError(f"Database does not exist: {database_name}") from e

def list_tables(self, namespace: Union[str, Identifier]) -> List[Identifier]:
"""List tables under the given namespace in the catalog (including non-Iceberg tables).
"""List Iceberg tables under the given namespace in the catalog.
Args:
namespace (str | Identifier): Namespace identifier to search.
Expand All @@ -410,11 +410,10 @@ def list_tables(self, namespace: Union[str, Identifier]) -> List[Identifier]:
TableName=self.dynamodb_table_name,
IndexName=DYNAMODB_NAMESPACE_GSI,
KeyConditionExpression=f"{DYNAMODB_COL_NAMESPACE} = :namespace",
FilterExpression=f"{_add_property_prefix(TABLE_TYPE)} = :table_type",
ExpressionAttributeValues={
":namespace": {
"S": database_name,
},
}
}
)
except (
Expand Down

0 comments on commit 5dcddad

Please sign in to comment.