Skip to content

Commit 4cb6e7c

Browse files
authored
patch flow-rs snapshot_num_partitions_override variable (#3390)
possible typo here for snapshot_num_partitions_override, let me know if any feedback on PR. thanks
1 parent 2172e89 commit 4cb6e7c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

nexus/flow-rs/src/grpc.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ impl FlowGrpcClient {
112112
let publication_name = job.publication_name.clone();
113113
let replication_slot_name = job.replication_slot_name.clone();
114114
let snapshot_num_rows_per_partition = job.snapshot_num_rows_per_partition;
115-
let snapshot_num_partitions_override = job.snapshot_num_rows_per_partition;
115+
let snapshot_num_partitions_override = job.snapshot_num_partitions_override;
116116
let snapshot_max_parallel_workers = job.snapshot_max_parallel_workers;
117117
let snapshot_num_tables_in_parallel = job.snapshot_num_tables_in_parallel;
118118
let Some(system) = TypeSystem::from_str_name(&job.system) else {

0 commit comments

Comments
 (0)