-
Notifications
You must be signed in to change notification settings - Fork 277
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'PMPY-2097' into 'integration'
PMPY-2097 Additional OpenAI queries Closes PMPY-2097 See merge request process-mining/pm4py/pm4py-core!996
- Loading branch information
Showing
10 changed files
with
791 additions
and
549 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,60 @@ | ||
| from pm4py.objects.petri_net.obj import PetriNet, Marking | ||
| from typing import Optional, Dict, Any | ||
| from pm4py.algo.querying.openai import net_to_descr | ||
| from pm4py.algo.querying.openai import perform_query | ||
| from enum import Enum | ||
| from pm4py.util import exec_utils, constants | ||
|
|
||
|
|
||
| class Parameters(Enum): | ||
| EXECUTE_QUERY = "execute_query" | ||
| API_KEY = "api_key" | ||
| EXEC_RESULT = "exec_result" | ||
|
|
||
|
|
||
| AVAILABLE_QUERIES = ["petri_diff_with_de_jure", "petri_describe_process"] | ||
|
|
||
|
|
||
| def query_wrapper(net: PetriNet, im: Marking, fm: Marking, type: str, args: Optional[Dict[Any, Any]] = None, parameters: Optional[Dict[Any, Any]] = None) -> str: | ||
| if parameters is None: | ||
| parameters = {} | ||
|
|
||
| if args is None: | ||
| args = {} | ||
|
|
||
| if type == "petri_diff_with_de_jure": | ||
| return petri_diff_with_de_jure(net, im, fm, parameters=parameters) | ||
| elif type == "petri_describe_process": | ||
| return petri_describe_process(net, im, fm, parameters=parameters) | ||
|
|
||
|
|
||
| def petri_diff_with_de_jure(net: PetriNet, im: Marking, fm: Marking, parameters: Optional[Dict[Any, Any]] = None) -> str: | ||
| if parameters is None: | ||
| parameters = {} | ||
|
|
||
| api_key = exec_utils.get_param_value(Parameters.API_KEY, parameters, constants.OPENAI_API_KEY) | ||
| execute_query = exec_utils.get_param_value(Parameters.EXECUTE_QUERY, parameters, api_key is not None) | ||
|
|
||
| query = net_to_descr.apply(net, im, fm, parameters=parameters) | ||
| query += "what are the differences of this process model with what would you expect (de-jure model) for the same process? Please only provide data or process-specific information, i.e., if the context is insufficient please not report any general consideration" | ||
|
|
||
| if not execute_query: | ||
| return query | ||
|
|
||
| return perform_query.apply(query, parameters=parameters) | ||
|
|
||
|
|
||
| def petri_describe_process(net: PetriNet, im: Marking, fm: Marking, parameters: Optional[Dict[Any, Any]] = None) -> str: | ||
| if parameters is None: | ||
| parameters = {} | ||
|
|
||
| api_key = exec_utils.get_param_value(Parameters.API_KEY, parameters, constants.OPENAI_API_KEY) | ||
| execute_query = exec_utils.get_param_value(Parameters.EXECUTE_QUERY, parameters, api_key is not None) | ||
|
|
||
| query = net_to_descr.apply(net, im, fm, parameters=parameters) | ||
| query += "could you describe the process represented in this Petri net?" | ||
|
|
||
| if not execute_query: | ||
| return query | ||
|
|
||
| return perform_query.apply(query, parameters=parameters) |
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,101 @@ | ||
| from pm4py.objects.ocel.obj import OCEL | ||
| from typing import Optional, Dict, Any | ||
| from pm4py.util import exec_utils, constants, xes_constants | ||
| from enum import Enum | ||
| import numpy as np | ||
|
|
||
|
|
||
| class Parameters(Enum): | ||
| INCLUDE_HEADER = "include_header" | ||
| MAX_LEN = "max_len" | ||
|
|
||
|
|
||
| def __transform_to_string(stru: str) -> str: | ||
| if stru.startswith("@@ocel_lif_activity_"): | ||
| return "Number of occurrences of the activity "+stru.split("@@ocel_lif_activity_")[1] | ||
| elif stru.startswith("@@object_lifecycle_unq_act"): | ||
| return "Number of unique activities in the lifecycle of the object" | ||
| elif stru.startswith("@@object_lifecycle_length"): | ||
| return "Number of events in the lifecycle of the object" | ||
| elif stru.startswith("@@object_lifecycle_duration"): | ||
| return "Duration of the lifecycle of the object" | ||
| elif stru.startswith("@@object_lifecycle_start_timestamp"): | ||
| return "Start timestamp of the lifecycle of the object" | ||
| elif stru.startswith("@@object_lifecycle_end_timestamp"): | ||
| return "Completion timestamp of the lifecycle of the object" | ||
| elif stru.startswith("@@object_degree_centrality"): | ||
| return "Degree centrality of the object in the object interaction graph" | ||
| elif stru.startswith("@@object_general_interaction_graph"): | ||
| return "Number of objects related in the object interaction graph" | ||
| elif stru.startswith("@@object_general_descendants_graph_descendants"): | ||
| return "Number of objects which follow the current object in the object descendants graph" | ||
| elif stru.startswith("@@object_general_inheritance_graph_ascendants"): | ||
| return "Number of objects which follow the current object in the object inheritance graph" | ||
| elif stru.startswith("@@object_general_descendants_graph_ascendants"): | ||
| return "Number of objects which precede the current object in the object descendants graph" | ||
| elif stru.startswith("@@object_general_inheritance_graph_descendants"): | ||
| return "Number of objects which precede the current object in the object descendants graph" | ||
| elif stru.startswith("@@object_cobirth"): | ||
| return "Number of objects starting their lifecycle together with the current object" | ||
| elif stru.startswith("@@object_codeath"): | ||
| return "Number of objects ending their lifecycle together with the current object" | ||
| elif stru.startswith("@@object_interaction_graph_"): | ||
| return "Number of object of type "+stru.split("@@object_interaction_graph_")[1]+" related to the current object in the object interaction graph" | ||
| elif stru.startswith("@@ocel_lif_path_"): | ||
| path = stru.split("@@ocel_lif_path_")[1] | ||
| act1 = path.split("##")[0] | ||
| act2 = path.split("##")[1] | ||
| return "Frequency of the path \""+act1+"\" -> \""+act2+"\" in the lifecycle of the object" | ||
|
|
||
| print(stru) | ||
| return None | ||
|
|
||
|
|
||
| def apply(ocel: OCEL, obj_type: str, parameters: Optional[Dict[Any, Any]] = None) -> str: | ||
| if parameters is None: | ||
| parameters = {} | ||
|
|
||
| include_header = exec_utils.get_param_value(Parameters.INCLUDE_HEADER, parameters, True) | ||
| max_len = exec_utils.get_param_value(Parameters.MAX_LEN, parameters, constants.OPENAI_MAX_LEN) | ||
|
|
||
| import pm4py | ||
|
|
||
| fea_df = pm4py.extract_ocel_features(ocel, obj_type, include_obj_id=False) | ||
|
|
||
| cols = [] | ||
|
|
||
| for c in fea_df.columns: | ||
| ser = fea_df[c] | ||
| ser1 = ser[ser != 0] | ||
| if len(ser1) > 0: | ||
| desc = __transform_to_string(c) | ||
| avg = np.average(ser1) | ||
| stdavg = 0 if avg == 0 or len(ser1) == 1 else np.std(ser1)/avg | ||
| cols.append([desc, len(ser1), stdavg, ser1]) | ||
|
|
||
| cols = sorted(cols, key=lambda x: (x[1], x[2], x[0]), reverse=True) | ||
|
|
||
| ret = ["\n"] | ||
|
|
||
| if include_header: | ||
| ret.append("Beforehand, a bit of notions.") | ||
| ret.append("Given an object-centric event log, the object interaction graph connects objects that are related in at least an event.") | ||
| ret.append("The object descendants graph connects objects related in at least an event, when the lifecycle of the second object starts after the lifecycle of the first.") | ||
| ret.append("The object inheritance graph connects objects when there an event that ends the lifecycle of the first object and starts the lifecycle of the second one.") | ||
| ret.append("\n\n") | ||
| ret.append("Given the following features:\n\n") | ||
|
|
||
| ret = " ".join(ret) | ||
|
|
||
| i = 0 | ||
| while i < len(cols): | ||
| if len(ret) >= max_len: | ||
| break | ||
|
|
||
| stru = cols[i][0]+": number of non-zero values: "+str(cols[i][1])+" ; quantiles of the non-zero: "+str(cols[i][3].quantile([0.0, 0.25, 0.5, 0.75, 1.0]).to_dict())+"\n" | ||
| ret = ret + stru | ||
|
|
||
| i = i + 1 | ||
|
|
||
| return ret | ||
|
|
Oops, something went wrong.