@@ -51,7 +51,7 @@ def workflow_event_to_nexus_link(
51
51
workflow_id = urllib .parse .quote (workflow_event .workflow_id )
52
52
run_id = urllib .parse .quote (workflow_event .run_id )
53
53
path = f"/namespaces/{ namespace } /workflows/{ workflow_id } /{ run_id } /history"
54
- query_params = _query_params_from_event_reference (workflow_event .event_ref )
54
+ query_params = _event_reference_to_query_params (workflow_event .event_ref )
55
55
return nexusrpc .Link (
56
56
url = urllib .parse .urlunparse ((scheme , "" , path , "" , query_params , "" )),
57
57
type = workflow_event .DESCRIPTOR .full_name ,
@@ -69,7 +69,7 @@ def nexus_link_to_workflow_event(
69
69
)
70
70
return None
71
71
try :
72
- event_ref = _event_reference_from_query_params (url .query )
72
+ event_ref = _query_params_to_event_reference (url .query )
73
73
except ValueError as err :
74
74
logger .warning (
75
75
f"Failed to parse event reference from Nexus link URL query parameters: { link } ({ err } )"
@@ -85,7 +85,7 @@ def nexus_link_to_workflow_event(
85
85
)
86
86
87
87
88
- def _query_params_from_event_reference (
88
+ def _event_reference_to_query_params (
89
89
event_ref : temporalio .api .common .v1 .Link .WorkflowEvent .EventReference ,
90
90
) -> str :
91
91
event_type_name = temporalio .api .enums .v1 .EventType .Name (event_ref .event_type )
@@ -98,7 +98,7 @@ def _query_params_from_event_reference(
98
98
)
99
99
100
100
101
- def _event_reference_from_query_params (
101
+ def _query_params_to_event_reference (
102
102
raw_query_params : str ,
103
103
) -> temporalio .api .common .v1 .Link .WorkflowEvent .EventReference :
104
104
"""Return an EventReference from the query params or raise ValueError."""
0 commit comments