MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / run_sql_timeout

Function run_sql_timeout

src/testdrive/src/action/set.rs:48–67  ·  view source on GitHub ↗
(
    mut cmd: BuiltinCommand,
    state: &mut State,
)

Source from the content-addressed store, hash-verified

46}
47
48pub fn run_sql_timeout(
49 mut cmd: BuiltinCommand,
50 state: &mut State,
51) -> Result<ControlFlow, anyhow::Error> {
52 let duration = cmd.args.string("duration")?;
53 let duration = if duration.to_lowercase() == "default" {
54 None
55 } else {
56 Some(humantime::parse_duration(&duration).context("parsing duration")?)
57 };
58 let force = cmd.args.opt_bool("force")?.unwrap_or(false);
59 cmd.args.done()?;
60 state.timeout = duration.unwrap_or(state.default_timeout);
61 if !force {
62 // Bump the timeout to be at least the default timeout unless the
63 // timeout has been forced.
64 state.timeout = cmp::max(state.timeout, state.default_timeout);
65 }
66 Ok(ControlFlow::Continue)
67}
68
69pub fn run_max_tries(
70 mut cmd: BuiltinCommand,

Callers 1

runMethod · 0.85

Calls 4

opt_boolMethod · 0.80
stringMethod · 0.45
contextMethod · 0.45
doneMethod · 0.45

Tested by

no test coverage detected