pm4py.streaming.algo.conformance.tbr.variants package

Submodules

pm4py.streaming.algo.conformance.tbr.variants.classic module

class pm4py.streaming.algo.conformance.tbr.variants.classic.Parameters[source]

Bases: object

ACTIVITY_KEY = 'pm4py:param:activity_key'
CASE_DICT_ID = 'case_dict_id'
CASE_ID_KEY = 'case_id_glue'
DICT_ID = 'dict_id'
DICT_VARIANT = 'dict_variant'
MAXIMUM_ITERATIONS_INVISIBLES = 'maximum_iterations_invisibles'
MISSING_DICT_ID = 'missing_dict_id'
REMAINING_DICT_ID = 'remaining_dict_id'
class pm4py.streaming.algo.conformance.tbr.variants.classic.TbrStreamingConformance(net, im, fm, parameters=None)[source]

Bases: pm4py.streaming.algo.interface.StreamingAlgorithm

build_dictionaries(parameters)[source]

Builds the dictionaries needed to store the information during the replay

Parameters

parameters

Parameters:
  • Parameters.DICT_VARIANT: type of dictionary to use

  • Parameters.CASE_DICT_ID: identifier of the dictionary hosting the markings (0)

  • Parameters.MISSING_DICT_ID: identifier of the dictionary hosting the missing tokens (1)

  • Parameters.REMAINING_DICT_ID: identifier of the dictionary hosting the remaining tokens (2)

decode_marking(ems)[source]

Decodes a marking from a generic dictionary to a Marking object

enable_trans_with_invisibles(marking, activity)[source]

Enables a visible transition (that is not enabled) through invisible transitions

Parameters
  • marking – Marking

  • activity – Activity to enable

Returns

New marking (where the transition CAN be enabled)

Return type

new_marking

encode_marking(mark)[source]

Encodes a marking for storage in generic dictionaries

encode_str(stru)[source]

Encodes a string for storage in generic dictionaries

get_paths_net()[source]

Gets the dictionary of shortest paths using invisibles transitions

Returns

Dictionary of shortest paths

Return type

dictio_spaths

get_status(case)[source]

Gets the status of an open case

Parameters

case – Case

message_activity_not_possible(activity, case)[source]

Sends a message if the activity is not possible according to the model

Parameters
  • activity – Activity

  • case – Case

message_case_not_in_dictionary(case)[source]

Sends a message if the provided case is not in the dictionary

Parameters
  • activity – Activity

  • case – Case

message_case_or_activity_not_in_event(event)[source]

Sends a message if the case or the activity are not there in the event

message_final_marking_not_reached(case, marking)[source]

Sends a message if the final marking could not be reached for the current case

Parameters

case – Case

message_missing_tokens(activity, case)[source]

Sends a message if the insertion of missing tokens occur

Parameters
  • activity – Activity

  • case – Case

reach_fm_with_invisibles(marking)[source]

Reaches the final marking using invisible transitions

Parameters

marking – Marking

Returns

New marking (hopely equal to the final marking)

Return type

new_marking

terminate(case)[source]

Terminate a case, checking if the final marking is reached

Parameters

case – Case ID

Returns

Dictionary containing: the marking, the count of missing and remaining tokens

Return type

dictio

terminate_all()[source]

Terminate all open cases

verify_tbr(case, activity)[source]

Verifies an activity happening in a case

Parameters
  • case – Case

  • activity – Activity

pm4py.streaming.algo.conformance.tbr.variants.classic.apply(net, im, fm, parameters=None)[source]

Method that creates the TbrStreamingConformance object

Parameters
  • net – Petri net

  • im – Initial marking

  • fm – Final marking

  • parameters – Parameters of the algorithm

Returns

Conformance streaming object

Return type

conf_stream_obj

Module contents