get tests passing again

Author: rerpha

tests/update_handlers/pva_update_handler_test.py

@@ -61,9 +61,9 @@ def test_update_handler_publishes_enum_update_f142(context, producer, pv_source_
         )
     )
 
-    # The assertions below assume that an ep01 and un00 message is sent after the f142
-    assert len(producer.published_payloads) == 3
-    pv_update_output = deserialise_f142(producer.published_payloads[-3])
+    # The assertions below assume that an ep01 message is sent after the f142
+    assert len(producer.published_payloads) == 2
+    pv_update_output = deserialise_f142(producer.published_payloads[-2])
     assert np.allclose(pv_update_output.value, pv_index)
     assert pv_update_output.source_name == pv_source_name
 
@@ -81,9 +81,9 @@ def test_update_handler_publishes_enum_update_f144(context, producer, pv_source_
         )
     )
 
-    # The assertions below assume that an ep01 and a un00 message is sent after the f142 and al00
-    assert len(producer.published_payloads) == 4
-    pv_update_output = deserialise_f144(producer.published_payloads[-4])
+    # The assertions below assume that an ep01 message is sent after the f142 and al00
+    assert len(producer.published_payloads) == 3
+    pv_update_output = deserialise_f144(producer.published_payloads[-3])
     assert np.allclose(pv_update_output.value, pv_index)
     assert pv_update_output.source_name == pv_source_name
 
@@ -118,9 +118,9 @@ def test_update_handler_publishes_scalar_update_f142(
         NTScalar(pv_type, valueAlarm=True).wrap(pv_value, timestamp=pv_timestamp_s)
     )
 
-    # The assertions below assume that an ep01 and a un00 message is sent after the f142
-    assert len(producer.published_payloads) == 3
-    pv_update_output = deserialise_f142(producer.published_payloads[-3])
+    # The assertions below assume that an ep01 message is sent after the f142
+    assert len(producer.published_payloads) == 2
+    pv_update_output = deserialise_f142(producer.published_payloads[-2])
     assert np.allclose(pv_update_output.value, pv_value)
     assert pv_update_output.source_name == pv_source_name
 
@@ -155,9 +155,9 @@ def test_update_handler_publishes_scalar_update_f144(
         NTScalar(pv_type, valueAlarm=True).wrap(pv_value, timestamp=pv_timestamp_s)
     )
 
-    # The assertions below assume that an ep01 and a un00 message is sent after the f142
-    assert len(producer.published_payloads) == 4
-    pv_update_output = deserialise_f144(producer.published_payloads[-4])
+    # The assertions below assume that an ep01 message is sent after the f142
+    assert len(producer.published_payloads) == 3
+    pv_update_output = deserialise_f144(producer.published_payloads[-3])
     assert np.allclose(pv_update_output.value, pv_value)
     assert pv_update_output.source_name == pv_source_name
 
@@ -187,9 +187,9 @@ def test_update_handler_publishes_alarm_update_f142(context, producer, pv_source
         )
     )
 
-    # The assertions below assume that an ep01 and a un00 message is sent after the f142
-    assert len(producer.published_payloads) == 3
-    pv_update_output = deserialise_f142(producer.published_payloads[-3])
+    # The assertions below assume that an ep01 message is sent after the f142
+    assert len(producer.published_payloads) == 2
+    pv_update_output = deserialise_f142(producer.published_payloads[-2])
     assert pv_update_output.source_name == pv_source_name
     assert pv_update_output.alarm_status == f142_AlarmStatus.HIGH  # type: ignore
     assert pv_update_output.alarm_severity == f142_AlarmSeverity.MINOR  # type: ignore
@@ -305,8 +305,8 @@ def test_update_handler_publishes_periodic_update_f142(
     )
 
     # The assertions below assume that an ep01 message is sent after the f142
-    assert len(producer.published_payloads) == 3
-    pv_update_output = deserialise_f142(producer.published_payloads[-3])
+    assert len(producer.published_payloads) == 2
+    pv_update_output = deserialise_f142(producer.published_payloads[-2])
     assert np.allclose(pv_update_output.value, pv_value)
     assert pv_update_output.source_name == pv_source_name