"""Lambda test module.""" from unittest.mock import patch from src import app as index @patch('src.app.Producer') def test_handler(kafkaProducerMock): """Test handler function.""" result = index.handler({'foo': 'bar'}, None) assert result == {'status': 'success'} kafkaProducerMock().produce.assert_called() kafkaProducerMock().flush.assert_called()