Skip to content

Commit 983d5fc

Browse files
committed
fix(workflows): fix branch version bug
1 parent e3fd728 commit 983d5fc

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

packages/common/chirp-workflow/core/src/ctx/workflow.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,7 @@ impl WorkflowCtx {
379379

380380
/// Creates a new workflow run with one more depth in the location.
381381
/// - **Not to be used directly by workflow users. For implementation uses only.**
382-
/// - **Remember to validate history after this branch is used.**
382+
/// - **Remember to validate latent history after this branch is used.**
383383
#[tracing::instrument(skip_all)]
384384
pub(crate) async fn branch(&mut self) -> WorkflowResult<Self> {
385385
self.custom_branch(self.input.clone(), self.version).await
@@ -400,7 +400,7 @@ impl WorkflowCtx {
400400
.commit_workflow_branch_event(
401401
self.workflow_id,
402402
&location,
403-
self.version,
403+
version,
404404
self.loop_location.as_ref(),
405405
)
406406
.await?;
@@ -409,6 +409,7 @@ impl WorkflowCtx {
409409
Ok(self.branch_inner(input, version, location))
410410
}
411411

412+
/// `custom_branch` with no history validation.
412413
pub(crate) fn branch_inner(
413414
&mut self,
414415
input: Arc<Box<serde_json::value::RawValue>>,

0 commit comments

Comments
 (0)