#[tokio::test]
    async fn test_local_with_control_plane() {
        let config = aws_config::load_defaults(BehaviorVersion::latest()).await;

        let creds = Credentials::from_keys("dummy", "dummy", None);

        let mut config_builder = aws_sdk_lambda::config::Builder::from(&config)
            .endpoint_url("http://0.0.0.0:9000")
            .region(Region::new("us-east-1"))
            .credentials_provider(creds);

        let lambda_client = aws_sdk_lambda::Client::from_conf(config_builder.build());

        let mut res = lambda_client
            .invoke_with_response_stream()
            .function_name("_")
            .payload(Blob::new("hello world"))
            .send()
            .await.unwrap();

        loop {
            match res.event_stream.recv().await {
                Ok(None) => break,
                Ok(Some(event)) => match event {
                    InvokeWithResponseStreamResponseEvent::InvokeComplete(_) => {
                        println!("invoke complete");
                        break;
                    }
                    InvokeWithResponseStreamResponseEvent::PayloadChunk(payload) => {
                        dbg!(&payload);
                    }
                    _ => todo!(),
                },
                err => {
                    dbg!(err);
                }
            }
        }
    }