Skip to content

Commit

Permalink
get last partition id as a side-effect
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Dec 5, 2023
1 parent 469fc51 commit 2168a8a
Showing 1 changed file with 10 additions and 1 deletion.
11 changes: 10 additions & 1 deletion flow/workflows/xmin_flow.go
Original file line number Diff line number Diff line change
Expand Up @@ -238,8 +238,17 @@ func XminFlowWorkflow(
return fmt.Errorf("xmin replication failed: %w", err)
}

lpIDSideEffect := workflow.SideEffect(ctx, func(ctx workflow.Context) interface{} {
return uuid.New().String()
})

var lpID string
if err := lpIDSideEffect.Get(&lpID); err != nil {
return fmt.Errorf("failed to get last partition id: %w", err)
}

state.LastPartition = &protos.QRepPartition{
PartitionId: uuid.New().String(),
PartitionId: lpID,
Range: &protos.PartitionRange{Range: &protos.PartitionRange_IntRange{IntRange: &protos.IntPartitionRange{Start: lastPartition}}},
}

Expand Down

0 comments on commit 2168a8a

Please sign in to comment.