def METHOD_NAME(
    config: Mapping[str, Any],
    configured_catalog: ConfiguredAirbyteCatalog,
    airbyte_message_1: AirbyteMessage,
    airbyte_message_2: AirbyteMessage,
    airbyte_state_message: AirbyteMessage,
    logger: MagicMock,
):
    with patch("destination_cumulio.destination.CumulioWriter") as cumulio_writer:
        destination_cumulio = DestinationCumulio()
        input_messages = [airbyte_state_message]
        result = list(
            destination_cumulio.write(config, configured_catalog, input_messages)
        )
        assert result == [airbyte_state_message]
        assert cumulio_writer.mock_calls == [
            call(config, configured_catalog, logger),
            call().delete_stream_entries("overwrite_stream"),
            call().flush_all(),  # The first flush_all is called before yielding the state message
            call().flush_all(),  # The second flush_all is called after going through all input messages
        ]