Function test_process_event_simple

tests/units/test_state.py:927–957

Test processing an event. Args: token: A token. mock_base_state_event_processor: The event processor. emitted_deltas: List to capture emitted deltas.

(
    token: str,
    mock_base_state_event_processor: BaseStateEventProcessor,
    emitted_deltas: list,
)

@pytest.mark.asyncio
async def test_process_event_simple(
    token: str,
    mock_base_state_event_processor: BaseStateEventProcessor,
    emitted_deltas: list,
):
    """Test processing an event.

    Args:
        token: A token.
        mock_base_state_event_processor: The event processor.
        emitted_deltas: List to capture emitted deltas.
    """
    event = Event(
        name=f"{TestState.get_full_name()}.set_num1",
        payload={"value": 69},
    )
    async with mock_base_state_event_processor as processor:
        await processor.enqueue(token, event)
    # The delta should contain the changes, including computed vars.
    assert emitted_deltas == [
        (
            token,
            {
                TestState.get_full_name(): {
                    "num1" + FIELD_MARKER: 69,
                    "sum" + FIELD_MARKER: 72.15,
                },
                GrandchildState3.get_full_name(): {"computed" + FIELD_MARKER: ""},
            },
        )
    ]


@pytest.mark.asyncio