Skip to content

retains_activity_filter

Retains activities base on their name (concept:name).

Parameters

activity_names: Iterable[str]
Activity names to filter.

Example

from pybeamline.sources import log_source
from pybeamline.sinks.print_sink import print_sink
from pybeamline.filters import retains_activity_filter

log_source(["ABC", "ACB", "EFG"]).pipe(
    retains_activity_filter("G")
).subscribe(print_sink())