"""Test for invoke_reserves_release_lambda task.""" from unittest.mock import patch import pytest from hooks.lambda_invoke.invocation_response import LambdaInvocationResponse from tasks.reserves_release.invoke_reserves_release_lambda import \ invoke_reserves_release_lambda_task @patch('tasks.reserves_release.invoke_reserves_release_lambda.OrchLambdaHook') def test_invoke_reserves_release_lambda_task_success( mock_orchlambdahook, mock_reserves_release_dag_run, lambda_response_success ): """Test for invoke_reserves_release_lambda task.""" mock_lambda_response = LambdaInvocationResponse(lambda_response_success) mock_orchlambdahook.return_value.invoke_lambda.return_value = mock_lambda_response invoke_reserves_release_lambda_task(mock_reserves_release_dag_run) mock_orchlambdahook.assert_called_once() @patch('tasks.reserves_release.invoke_reserves_release_lambda.OrchLambdaHook') def test_invoke_reserves_release_lambda_task_error( mock_orchlambdahook, mock_reserves_release_dag_run, lambda_response_error ): """Test for invoke_reserves_release_lambda task.""" mock_lambda_response = LambdaInvocationResponse(lambda_response_error) mock_orchlambdahook.return_value.invoke_lambda.return_value = mock_lambda_response with pytest.raises(Exception): invoke_reserves_release_lambda_task(mock_reserves_release_dag_run) mock_orchlambdahook.assert_called_once()