diff --git a/src/daft-connect/src/lib.rs b/src/daft-connect/src/lib.rs index a5c842e1cb..53f13f4ced 100644 --- a/src/daft-connect/src/lib.rs +++ b/src/daft-connect/src/lib.rs @@ -361,9 +361,19 @@ impl SparkConnectService for DaftSparkConnectService { #[tracing::instrument(skip_all)] async fn release_execute( &self, - _request: Request, + request: Request, ) -> Result, Status> { - unimplemented_err!("release_execute operation is not yet implemented") + let request = request.into_inner(); + + let session = self.get_session(&request.session_id)?; + + let response = ReleaseExecuteResponse { + session_id: session.client_side_session_id().to_string(), + server_side_session_id: session.server_side_session_id().to_string(), + operation_id: None, // todo: set but not strictly required + }; + + Ok(Response::new(response)) } #[tracing::instrument(skip_all)]