status-im/spiff-arena
2
0
Fork 0
mirror of https://github.com/status-im/spiff-arena.git synced 2025-02-06 23:24:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

failing test.

Browse Source
This commit is contained in:
Dan 2023-02-17 12:10:32 -05:00
parent ef4297331d
commit ecbd30af00
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
spiffworkflow-backend/tests/spiffworkflow_backend/unit/test_message_service_2.py
View File

@ -85,6 +85,12 @@ class TestMessageService(BaseTest):
## No error when calling with the correct parameters ## No error when calling with the correct parameters
response = message_send("approval_result", {'payload': {'po_number' : 1001, 'customer_id': 'Sartography'}}) response = message_send("approval_result", {'payload': {'po_number' : 1001, 'customer_id': 'Sartography'}})
## There is no longer a waiting message
waiting_messages = MessageInstanceModel.query. \
filter_by(message_type = "receive"). \
filter_by(process_instance_id = self.process_instance.id).all()
assert len(waiting_messages) == 0
def assure_a_message_was_sent(self): def assure_a_message_was_sent(self):
# There should be one new send message for the given process instance. # There should be one new send message for the given process instance.
send_messages = MessageInstanceModel.query. \ send_messages = MessageInstanceModel.query. \
@ -110,8 +116,6 @@ class TestMessageService(BaseTest):
waiting_message = waiting_messages[0] waiting_message = waiting_messages[0]
self.assure_correlation_properties_are_right(waiting_message) self.assure_correlation_properties_are_right(waiting_message)
def assure_correlation_properties_are_right(self, message): def assure_correlation_properties_are_right(self, message):
# Correlation Properties should match up # Correlation Properties should match up
po_curr = next(c for c in message.message_correlations if c.name == "po_number") po_curr = next(c for c in message.message_correlations if c.name == "po_number")