Skip to content

Commit 58cf428

Browse files
committed
record all queries
1 parent 8915d09 commit 58cf428

File tree

1 file changed

+14
-12
lines changed

1 file changed

+14
-12
lines changed

monitoring/uss_qualifier/scenarios/astm/utm/test_steps.py

Lines changed: 14 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -661,23 +661,24 @@ def set_uss_available(
661661
"USS availability successfully set to 'Available'", [dss.participant_id]
662662
) as check:
663663
try:
664-
availability_response, avail_query = dss.get_uss_availability(
664+
availability_response, get_avail_query = dss.get_uss_availability(
665665
uss_sub,
666666
scope=Scope.AvailabilityArbitration,
667667
)
668-
availability_version, avail_query = dss.set_uss_availability(
668+
scenario.record_query(get_avail_query)
669+
availability_version, set_avail_query = dss.set_uss_availability(
669670
uss_sub,
670671
True,
671672
availability_response.version,
672673
)
673-
scenario.record_query(avail_query)
674+
scenario.record_query(set_avail_query)
674675
except QueryError as e:
675676
scenario.record_queries(e.queries)
676-
avail_query = e.queries[0]
677+
q = e.queries[0]
677678
check.record_failed(
678679
summary=f"Availability of USS {uss_sub} could not be set to available",
679-
details=f"DSS responded code {avail_query.status_code}; {e}",
680-
query_timestamps=[avail_query.request.timestamp],
680+
details=f"DSS responded code {q.status_code}; {e}",
681+
query_timestamps=[q.request.timestamp],
681682
)
682683
return availability_version
683684

@@ -698,23 +699,24 @@ def set_uss_down(
698699
"USS availability successfully set to 'Down'", [dss.participant_id]
699700
) as check:
700701
try:
701-
availability_response, avail_query = dss.get_uss_availability(
702+
availability_response, get_avail_query = dss.get_uss_availability(
702703
uss_sub,
703704
scope=Scope.AvailabilityArbitration,
704705
)
705-
availability_version, avail_query = dss.set_uss_availability(
706+
scenario.record_query(get_avail_query)
707+
availability_version, set_avail_query = dss.set_uss_availability(
706708
uss_sub,
707709
False,
708710
availability_response.version,
709711
)
710-
scenario.record_query(avail_query)
712+
scenario.record_query(set_avail_query)
711713
except QueryError as e:
712714
scenario.record_queries(e.queries)
713-
avail_query = e.queries[0]
715+
q = e.queries[0]
714716
check.record_failed(
715717
summary=f"Availability of USS {uss_sub} could not be set to down",
716-
details=f"DSS responded code {avail_query.status_code}; {e}",
717-
query_timestamps=[avail_query.request.timestamp],
718+
details=f"DSS responded code {q.status_code}; {e}",
719+
query_timestamps=[q.request.timestamp],
718720
)
719721
return availability_version
720722

0 commit comments

Comments
 (0)