Synchronization issue with streams
______________________ test_events_on_session_node[False] ______________________
beforestart = False
session = <bliss.common.session.Session object at 0x7fdc5f3dac10>
@pytest.mark.parametrize("beforestart", [True, False])
def test_events_on_session_node(beforestart, session):
events = _count_node_events(beforestart, session, session.name)
# New node events: root nodes, scan, scan master (timer),
# epoch, elapsed_time, diode controller, diode
> assert set(events.keys()) == {"NEW_NODE", "NEW_DATA", "END_SCAN"}
E AssertionError: assert {'END_SCAN', 'NEW_NODE'} == {'END_SCAN', ...', 'NEW_NODE'}
E Extra items in the right set:
E 'NEW_DATA'
E Full diff:
E - {'END_SCAN', 'NEW_NODE'}
E + {'NEW_DATA', 'END_SCAN', 'NEW_NODE'}
E ? ++++++++++++
tests/scans/test_publishing.py:558: AssertionError
Edited by Wout De Nolf