Skip to content

Commit

Permalink
fix missing implementation of check
Browse files Browse the repository at this point in the history
  • Loading branch information
mickmis committed Mar 25, 2024
1 parent 059954a commit 8d5cea3
Showing 1 changed file with 25 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -274,6 +274,31 @@ def _steps_create_subs_at_each_dss(self):
query_timestamps=[r.request.timestamp],
)

for other_dss in {self._dss, *self._secondary_instances} - {dss}:
other_dss_sub = other_dss.get_subscription(sub_id)
with self.check(
"Get Subscription by ID",
other_dss.participant_id,
) as check:
if not other_dss_sub.success:
check.record_failed(
summary="Get subscription query failed",
details=f"Failed to retrieved a subscription from DSS with code {other_dss_sub.status_code}: {other_dss_sub.error_message}",
query_timestamps=[other_dss_sub.request.timestamp],
)

with self.check(
"Subscription may be retrieved from all other DSS instances",
[dss.participant_id, other_dss.participant_id],
) as check:
# status may have been 404
if other_dss_sub.status_code != 200:
check.record_failed(
summary="Subscription created on a DSS instance was not found on another instance",
details=f"Subscription {sub_id} created on DSS instance {dss.participant_id} was not found on DSS instance {other_dss.participant_id} (error message: {other_dss_sub.error_message}).",
query_timestamps=[other_dss_sub.request.timestamp],
)

self.end_test_step()

def _put_op_intent(
Expand Down

0 comments on commit 8d5cea3

Please sign in to comment.