Skip to content

Commit 557963e

Browse files
committed
small fix with the callback states actions
Signed-off-by: oEscal <[email protected]>
1 parent e222ee4 commit 557963e

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

serverlessworkflow/sdk/state_machine_generator.py

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -340,7 +340,7 @@ def callback_state_details(self):
340340
if isinstance(self.current_state, CallbackState):
341341
self.state_to_machine_state(["callback_state", "state"])
342342
action = self.current_state.action
343-
if action and action.functionRef:
343+
if action:
344344
self.generate_actions_info(
345345
machine_state=self.state_machine.get_state(self.current_state.name),
346346
state_name=self.current_state.name,
@@ -542,14 +542,18 @@ def get_action_function(self, state: NestedState, f_name: str):
542542
state.metadata = {"function": current_function}
543543
break
544544

545-
def get_action_event(self, state: NestedState, e_name: str, er_name: str = ""):
545+
def get_action_event(self, state: NestedState, e_name: str, er_name: str = None):
546546
if self.workflow.events:
547+
state.metadata = {"event": (None if er_name is None else {})}
547548
for event in self.workflow.events:
548549
current_event = event.serialize().__dict__
549550
if current_event["name"] == e_name:
550-
state.metadata = {"event": current_event}
551-
if current_event["name"] == er_name:
552-
state.metadata = {"result_event": current_event}
551+
if type(state.metadata["event"]) == dict:
552+
state.metadata["event"]["trigger"] = current_event
553+
else:
554+
state.metadata["event"] = current_event
555+
if er_name and current_event["name"] == er_name:
556+
state.metadata["event"]["result"] = current_event
553557

554558
def subflow_state_name(self, action: Action, subflow: Workflow):
555559
return (

0 commit comments

Comments
 (0)