Skip to content

Commit fb484fc

Browse files
authored
Merge pull request #434 from sartography/get-emerson-working
hack to get messages working
2 parents 15f4eec + e380fe7 commit fb484fc

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

SpiffWorkflow/bpmn/specs/event_definitions/message.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ def catches(self, my_task, event):
2828
correlated = True
2929
else:
3030
# Otherwise we have to check to make sure any existing keys match
31-
correlated = all([event.correlations.get(key) == correlations.get(key) for key in event.correlations ])
31+
correlated = any([event.correlations.get(key) == correlations.get(key) for key in event.correlations ])
3232
return self == event.event_definition and correlated
3333

3434
def catch(self, my_task, event=None):

tests/SpiffWorkflow/bpmn/CollaborationTest.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,9 +60,11 @@ def testBpmnMessage(self):
6060
self.assertEqual('from_name', events[0].value[0].retrieval_expression)
6161
self.assertEqual('lover_name', events[0].value[0].name)
6262

63+
payload = {'from_name': 'Peggy', 'other_nonsense': 1001}
6364
message = BpmnEvent(
6465
receive.task_spec.event_definition,
65-
{'from_name': 'Peggy', 'other_nonsense': 1001}
66+
payload,
67+
receive.task_spec.event_definition.get_correlations(receive, payload),
6668
)
6769
self.workflow.send_event(message)
6870
self.workflow.do_engine_steps()

0 commit comments

Comments
 (0)