Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 7 additions & 2 deletions merlin/schema/schema.py
Original file line number Diff line number Diff line change
Expand Up @@ -285,7 +285,9 @@ def excluding(self, selector) -> "Schema":
def apply_inverse(self, selector) -> "Schema":
return self.excluding(selector)

def select_by_tag(self, tags: Union[Union[str, Tags], List[Union[str, Tags]]]) -> "Schema":
def select_by_tag(
self, tags: Union[Union[str, Tags], List[Union[str, Tags]], TagSet]
) -> "Schema":
"""Select matching columns from this Schema object using a list of tags

Parameters
Expand All @@ -299,8 +301,11 @@ def select_by_tag(self, tags: Union[Union[str, Tags], List[Union[str, Tags]]]) -
New object containing only the ColumnSchemas of selected columns

"""
if not isinstance(tags, (list, tuple)):
if isinstance(tags, tuple):
tags = list(tags)
if not isinstance(tags, list):
tags = [tags]
tags = TagSet(tags)

selected_schemas = {}

Expand Down