pm4py.algo.filtering.polars.rework.rework_filter module#

class pm4py.algo.filtering.polars.rework.rework_filter.Parameters(*values)[source]#

Bases: Enum

CASE_ID_KEY = 'pm4py:param:case_id_key'#
ACTIVITY_KEY = 'pm4py:param:activity_key'#
MIN_OCCURRENCES = 'min_occurrences'#
pm4py.algo.filtering.polars.rework.rework_filter.apply(df: polars.LazyFrame, parameters: Dict[str | Parameters, Any] | None = None) → polars.LazyFrame[source]#

Filters the cases where the specified activity occurs at least min_occurrences times.

Parameters:

  • df – LazyFrame

  • parameters –

    Parameters of the algorithm, including:

    Parameters.CASE_ID_KEY -> Column that contains the Case ID Parameters.ACTIVITY_KEY -> Column that contains the activity Parameters.MIN_OCCURRENCES -> Minimum occurrences of the activity (default: 2)

Returns:

Filtered LazyFrame

Return type:

df

pm4py.algo.filtering.polars.rework.rework_filter.apply_activity_set(df: polars.LazyFrame, activities: Set[str], parameters: Dict[str | Parameters, Any] | None = None) → polars.LazyFrame[source]#

Filters the cases where at least one of the specified activities occurs at least min_occurrences times.

Parameters:

  • df – LazyFrame

  • activities – Set of activities to check for rework

  • parameters – Parameters of the algorithm

Returns:

Filtered LazyFrame

Return type:

df