@pytest.fixture(autouse=True)
    def setup_attrs(self, minimal_app_for_internal_api: Flask) -> Generator:
        self.app = minimal_app_for_internal_api
        self.client = self.app.test_client()  
        mock_test_method.reset_mock()
        mock_test_method.side_effect = None
        with mock.patch(
            "airflow.api_internal.endpoints.rpc_api_endpoint._initialize_map"
        ) as mock_initialize_map:
            mock_initialize_map.return_value = {TEST_METHOD_NAME: mock_test_method}
            yield mock_initialize_map
    @pytest.mark.parametrize(
        "input_data, method_result, method_params, expected_code",
        [
            ({"jsonrpc": "2.0", "method": TEST_METHOD_NAME, "params": ""}, "test_me", None, 200),
            ({"jsonrpc": "2.0", "method": TEST_METHOD_NAME, "params": ""}, None, None, 200),
            (
                {
                    "jsonrpc": "2.0",
                    "method": TEST_METHOD_NAME,
                    "params": json.dumps(BaseSerialization.serialize({"dag_id": 15, "task_id": "fake-task"})),
                },
                ("dag_id_15", "fake-task", 1),
                {"dag_id": 15, "task_id": "fake-task"},
                200,
            ),
        ],
    )
    def test_method(self, input_data, method_result, method_params, expected_code):