Skip to content

Commit

Permalink
maybe fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
andrewgazelka committed Dec 4, 2024
1 parent e82f9e5 commit 89919a4
Showing 1 changed file with 12 additions and 2 deletions.
14 changes: 12 additions & 2 deletions src/daft-connect/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -361,9 +361,19 @@ impl SparkConnectService for DaftSparkConnectService {
#[tracing::instrument(skip_all)]
async fn release_execute(
&self,
_request: Request<ReleaseExecuteRequest>,
request: Request<ReleaseExecuteRequest>,
) -> Result<Response<ReleaseExecuteResponse>, 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)]
Expand Down

0 comments on commit 89919a4

Please sign in to comment.