Skip to content

Commit 85cccb7

Browse files
SamChou19815meta-codesync[bot]
authored andcommitted
[flow][oxidation] A rust port specific types_first.max_files_checked_per_worker config option
Reviewed By: panagosg7 Differential Revision: D98156857 fbshipit-source-id: d1ad1fb0924cdc74a184dc01380d21f7f018bbf2
1 parent bbf6280 commit 85cccb7

3 files changed

Lines changed: 29 additions & 1 deletion

File tree

rust_port/crates/flow_cli/src/command_utils.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,7 @@ pub(super) fn make_options(
144144
log_saving,
145145
long_lived_workers,
146146
max_files_checked_per_worker,
147+
max_files_checked_per_worker_rust_port,
147148
max_header_tokens,
148149
max_seconds_for_check_per_worker,
149150
max_workers,
@@ -242,7 +243,8 @@ pub(super) fn make_options(
242243
lazy_mode,
243244
Some(LazyMode::Lazy) | Some(LazyMode::WatchmanDeprecated)
244245
);
245-
let max_files_checked_per_worker = max_files_checked_per_worker as i32;
246+
let max_files_checked_per_worker =
247+
max_files_checked_per_worker_rust_port.unwrap_or(max_files_checked_per_worker) as i32;
246248
let max_header_tokens = max_header_tokens as i32;
247249
let merge_timeout = merge_timeout.map(|t| t as f64);
248250
let use_unknown_in_catch_variables = use_unknown_in_catch_variables.unwrap_or(false);

rust_port/crates/flow_cli/src/flowconfig.rs

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,7 @@ pub(super) mod opts {
130130
pub(crate) log_saving: BTreeMap<String, LogSaving>,
131131
pub(crate) long_lived_workers: bool,
132132
pub(crate) max_files_checked_per_worker: u32,
133+
pub(crate) max_files_checked_per_worker_rust_port: Option<u32>,
133134
pub(crate) max_header_tokens: u32,
134135
pub(crate) max_seconds_for_check_per_worker: f64,
135136
pub(crate) max_workers: Option<u32>,
@@ -274,6 +275,7 @@ pub(super) mod opts {
274275
log_saving: BTreeMap::new(),
275276
long_lived_workers: false,
276277
max_files_checked_per_worker: 100,
278+
max_files_checked_per_worker_rust_port: None,
277279
max_header_tokens: 10,
278280
max_seconds_for_check_per_worker: 5.0,
279281
max_workers: None,
@@ -737,6 +739,22 @@ pub(super) mod opts {
737739
)
738740
}
739741

742+
fn max_files_checked_per_worker_rust_port_parser(
743+
values: RawValues,
744+
config: &mut Opts,
745+
) -> Result<(), OptError> {
746+
parse_uint(
747+
|opts, v| {
748+
opts.max_files_checked_per_worker_rust_port = Some(v);
749+
Ok(())
750+
},
751+
None,
752+
false,
753+
values,
754+
config,
755+
)
756+
}
757+
740758
fn max_seconds_for_check_per_worker_parser(
741759
values: RawValues,
742760
config: &mut Opts,
@@ -2586,6 +2604,9 @@ pub(super) mod opts {
25862604
"types_first.max_files_checked_per_worker" => {
25872605
Some(max_files_checked_per_worker_parser(values, config))
25882606
}
2607+
"types_first.max_files_checked_per_worker.rust_port" => Some(
2608+
max_files_checked_per_worker_rust_port_parser(values, config),
2609+
),
25892610
"types_first.max_seconds_for_check_per_worker" => {
25902611
Some(max_seconds_for_check_per_worker_parser(values, config))
25912612
}

src/commands/config/flowConfig.ml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -467,6 +467,8 @@ module Opts = struct
467467
let max_files_checked_per_worker_parser =
468468
uint (fun opts v -> Ok { opts with max_files_checked_per_worker = v })
469469

470+
let max_files_checked_per_worker_rust_port_parser = uint (fun opts _v -> Ok opts)
471+
470472
let max_seconds_for_check_per_worker_parser =
471473
uint (fun opts v -> Ok { opts with max_seconds_for_check_per_worker = float v })
472474

@@ -1321,6 +1323,9 @@ module Opts = struct
13211323
string (fun opts v -> Ok { opts with stylex_shorthand_prop = Some v })
13221324
);
13231325
("types_first.max_files_checked_per_worker", max_files_checked_per_worker_parser);
1326+
( "types_first.max_files_checked_per_worker.rust_port",
1327+
max_files_checked_per_worker_rust_port_parser
1328+
);
13241329
("types_first.max_seconds_for_check_per_worker", max_seconds_for_check_per_worker_parser);
13251330
("unsuppressable_error_codes", unsuppressable_error_codes_parser);
13261331
("use_unknown_in_catch_variables", use_unknown_in_catch_variables_parser);

0 commit comments

Comments
 (0)