Selene Hines
04/24/2023, 6:19 AMTim Castillo
04/24/2023, 5:38 PMclass AssetPrefixAssetSelection(AssetSelection):
def __init__(self, prefix: Sequence[str]):
self.prefix = prefix
def resolve_inner(self, asset_graph: AssetGraph) -> AbstractSet[AssetKey]:
keys = set()
for asset_key in asset_graph.all_asset_keys:
if asset_key.path[: len(self.prefix)] == self.prefix:
keys.add(asset_key)
return keys
my_selection = AssetPrefixAssetSelection(prefix=["my", "prefix"])
Selene Hines
04/24/2023, 5:50 PM