Skip to content

Commit fcd05c0

Browse files
committed
fix(sdf): Force a new change set when testing a function
1 parent 647a77d commit fcd05c0

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

lib/sdf-server/src/service/v2/func/test_execute.rs

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,14 +3,16 @@ use axum::{
33
Json,
44
};
55
use dal::{
6-
func::authoring::FuncAuthoringClient, ChangeSetId, ComponentId, Func, FuncId, WorkspacePk,
6+
func::authoring::FuncAuthoringClient, ChangeSet, ChangeSetId, ComponentId, Func, FuncId,
7+
WorkspacePk,
78
};
89
use serde::{Deserialize, Serialize};
910
use si_events::{audit_log::AuditLogKind, FuncRunId};
1011

1112
use super::FuncAPIResult;
1213
use crate::{
1314
extract::{AccessBuilder, HandlerContext, PosthogClient},
15+
service::force_change_set_response::ForceChangeSetResponse,
1416
track,
1517
};
1618

@@ -36,10 +38,11 @@ pub async fn test_execute(
3638
Host(host_name): Host,
3739
Path((_workspace_pk, change_set_id, func_id)): Path<(WorkspacePk, ChangeSetId, FuncId)>,
3840
Json(request): Json<TestExecuteFuncRequest>,
39-
) -> FuncAPIResult<Json<TestExecuteFuncResponse>> {
40-
let ctx = builder
41+
) -> FuncAPIResult<ForceChangeSetResponse<TestExecuteFuncResponse>> {
42+
let mut ctx = builder
4143
.build(access_builder.build(change_set_id.into()))
4244
.await?;
45+
let force_change_set_id = ChangeSet::force_new(&mut ctx).await?;
4346

4447
let func = Func::get_by_id_or_error(&ctx, func_id).await?;
4548
let func_run_id = FuncAuthoringClient::test_execute_func(
@@ -75,5 +78,8 @@ pub async fn test_execute(
7578
.await?;
7679
ctx.commit().await?;
7780

78-
Ok(Json(TestExecuteFuncResponse { func_run_id }))
81+
Ok(ForceChangeSetResponse::new(
82+
force_change_set_id,
83+
TestExecuteFuncResponse { func_run_id },
84+
))
7985
}

0 commit comments

Comments
 (0)