Skip to content

Commit 79b1f32

Browse files
committed
set correlations on message receieve
1 parent 2a8e3f0 commit 79b1f32

File tree

1 file changed

+3
-0
lines changed
  • SpiffWorkflow/bpmn/specs/event_definitions

1 file changed

+3
-0
lines changed

SpiffWorkflow/bpmn/specs/event_definitions/message.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,9 @@ def catches(self, my_task, event):
3333

3434
def catch(self, my_task, event=None):
3535
self.update_internal_data(my_task, event)
36+
if event is not None:
37+
correlations = self.get_correlations(my_task, event.payload)
38+
my_task.workflow.correlations.update(correlations)
3639
super().catch(my_task, event)
3740

3841
def throw(self, my_task):

0 commit comments

Comments
 (0)