aa8a53f687
Updates all the various files utilized in the system and idempotence tests to directly use the corresponding 'style_edition' configuration as opposed to keeping the original 'version' values and relying on the mapping.
178 lines
5.8 KiB
Rust
178 lines
5.8 KiB
Rust
// rustfmt-style_edition: 2024
|
|
fn main() {
|
|
// sample 1
|
|
{
|
|
{
|
|
{
|
|
{
|
|
{
|
|
let push_ident = if let Some(&node_id) =
|
|
subgraph_nodes.get(pull_to_push_idx)
|
|
{
|
|
self.node_id_as_ident(node_id, false)
|
|
} else {
|
|
// Entire subgraph is pull (except for a single send/push handoff output).
|
|
assert_eq!(
|
|
1,
|
|
send_ports.len(),
|
|
"If entire subgraph is pull, should have only one handoff output."
|
|
);
|
|
send_ports[0].clone()
|
|
};
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// sample 2
|
|
{
|
|
{
|
|
{
|
|
{
|
|
{
|
|
let push_ident = if let Some(&node_id) =
|
|
subgraph_nodes.get(pull_to_push_idx)
|
|
{
|
|
self.node_id_as_ident(node_id, false)
|
|
} else {
|
|
// Entire subgraph is pull (except for a single send/push handoff output).
|
|
assert_eq!(
|
|
1,
|
|
send_ports.len(),
|
|
"If entire subgraph is pull, should have only one handoff output."
|
|
);
|
|
send_ports[0].clone()
|
|
};
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// sample 3
|
|
{
|
|
{
|
|
{
|
|
{
|
|
{
|
|
let push_ident = if let Some(&node_id) =
|
|
subgraph_nodes.get(pull_to_push_idx)
|
|
{
|
|
self.node_id_as_ident(node_id, false)
|
|
} else {
|
|
// Entire subgraph is pull (except for a single send/push handoff output).
|
|
assert_eq!(
|
|
1,
|
|
send_ports.len(),
|
|
"If entire subgraph is pull, should have only one handoff output."
|
|
);
|
|
send_ports[0].clone()
|
|
};
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// sample 4
|
|
{
|
|
{
|
|
{
|
|
{
|
|
{
|
|
let push_ident = if let Some(&node_id) =
|
|
subgraph_nodes.get(pull_to_push_idx)
|
|
{
|
|
self.node_id_as_ident(node_id, false)
|
|
} else {
|
|
// Entire subgraph is pull (except for a single send/push handoff output).
|
|
assert_eq!(
|
|
1,
|
|
send_ports.len(),
|
|
"If entire subgraph is pull, should have only one handoff output."
|
|
);
|
|
send_ports[0].clone()
|
|
};
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// sample 5
|
|
{
|
|
{
|
|
{
|
|
{
|
|
{
|
|
let push_ident = if let Some(&node_id) =
|
|
subgraph_nodes.get(pull_to_push_idx)
|
|
{
|
|
self.node_id_as_ident(node_id, false)
|
|
} else {
|
|
// Entire subgraph is pull (except for a single send/push handoff output).
|
|
assert_eq!(
|
|
1,
|
|
send_ports.len(),
|
|
"If entire subgraph is pull, should have only one handoff output."
|
|
);
|
|
send_ports[0].clone()
|
|
};
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// sample 6
|
|
{
|
|
{
|
|
{
|
|
{
|
|
{
|
|
let push_ident = if let Some(&node_id) =
|
|
subgraph_nodes.get(pull_to_push_idx)
|
|
{
|
|
self.node_id_as_ident(node_id, false)
|
|
} else {
|
|
// Entire subgraph is pull (except for a single send/push handoff output).
|
|
assert_eq!(
|
|
1,
|
|
send_ports.len(),
|
|
"If entire subgraph is pull, should have only one handoff output."
|
|
);
|
|
send_ports[0].clone()
|
|
};
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// sample 7
|
|
{
|
|
{
|
|
{
|
|
{
|
|
{
|
|
let push_ident = if let Some(&node_id) =
|
|
subgraph_nodes.get(pull_to_push_idx)
|
|
{
|
|
self.node_id_as_ident(node_id, false)
|
|
} else {
|
|
// Entire subgraph is pull (except for a single send/push handoff output).
|
|
assert_eq!(
|
|
1,
|
|
send_ports.len(),
|
|
"If entire subgraph is pull, should have only one handoff output."
|
|
);
|
|
send_ports[0].clone()
|
|
};
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|