def METHOD_NAME(
        mock_connection: MagicMock,
        mock_writer: MagicMock,
        config: Dict[str, str],
        configured_stream1: ConfiguredAirbyteStream,
        configured_stream2: ConfiguredAirbyteStream,
        airbyte_message1: AirbyteMessage,
        airbyte_message2: AirbyteMessage,
        airbyte_state_message: AirbyteMessage,
):
    # Overwrite triggers a delete
    configured_stream1.destination_sync_mode = DestinationSyncMode.overwrite
    catalog = ConfiguredAirbyteCatalog(streams=[configured_stream1, configured_stream2])
    destination = DestinationDatabend()
    result = destination.write(config, catalog, [airbyte_message1, airbyte_state_message, airbyte_message2])
    assert list(result) == [airbyte_state_message]
    mock_writer.return_value.delete_table.assert_called_once_with("table1")
    mock_writer.return_value.create_raw_table.mock_calls = [call(mock_connection, "table1"), call(mock_connection, "table2")]