Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion hyperactor/src/data.rs
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ impl Named for bytes::Bytes {
#[doc(hidden)] // not part of the public API
#[macro_export]
macro_rules! intern_typename {
($key:ty, $format_string:expr_2021, $($args:ty),+) => {
($key:ty, $format_string:expr, $($args:ty),+) => {
{
static CACHE: std::sync::LazyLock<$crate::dashmap::DashMap<std::any::TypeId, &'static str>> =
std::sync::LazyLock::new($crate::dashmap::DashMap::new);
Expand Down
4 changes: 2 additions & 2 deletions hyperactor/src/parse.rs
Original file line number Diff line number Diff line change
Expand Up @@ -104,9 +104,9 @@ impl<'a> Iterator for Lexer<'a> {
// TODO: improve error reporting here
macro_rules! parse {
(
$token_stream:expr_2021;
$token_stream:expr;
$(
$($pattern:pat_param)* => $constructor:expr_2021
$($pattern:pat_param)* => $constructor:expr
),* $(,)?
) => {
{
Expand Down
8 changes: 4 additions & 4 deletions hyperactor/src/reference.rs
Original file line number Diff line number Diff line change
Expand Up @@ -253,13 +253,13 @@ macro_rules! id {
($world:ident) => {
$crate::reference::WorldId(stringify!($world).to_string())
};
($world:ident [$rank:expr_2021]) => {
($world:ident [$rank:expr]) => {
$crate::reference::ProcId::Ranked(
$crate::reference::WorldId(stringify!($world).to_string()),
$rank,
)
};
($world:ident [$rank:expr_2021] . $actor:ident) => {
($world:ident [$rank:expr] . $actor:ident) => {
$crate::reference::ActorId(
$crate::reference::ProcId::Ranked(
$crate::reference::WorldId(stringify!($world).to_string()),
Expand All @@ -269,7 +269,7 @@ macro_rules! id {
0,
)
};
($world:ident [$rank:expr_2021] . $actor:ident [$pid:expr_2021]) => {
($world:ident [$rank:expr] . $actor:ident [$pid:expr]) => {
$crate::reference::ActorId(
$crate::reference::ProcId::Ranked(
$crate::reference::WorldId(stringify!($world).to_string()),
Expand All @@ -285,7 +285,7 @@ macro_rules! id {
stringify!($actor).to_string(),
)
};
($world:ident [$rank:expr_2021] . $actor:ident [$pid:expr_2021] [$port:expr_2021]) => {
($world:ident [$rank:expr] . $actor:ident [$pid:expr] [$port:expr]) => {
$crate::reference::PortId(
$crate::reference::ActorId(
$crate::reference::ProcId::Ranked(
Expand Down
2 changes: 1 addition & 1 deletion hyperactor_mesh/src/actor_mesh.rs
Original file line number Diff line number Diff line change
Expand Up @@ -668,7 +668,7 @@ mod tests {
// These tests are parametric over allocators.
#[macro_export]
macro_rules! actor_mesh_test_suite {
($allocator:expr_2021) => {
($allocator:expr) => {
use std::assert_matches::assert_matches;

use ndslice::extent;
Expand Down
2 changes: 1 addition & 1 deletion hyperactor_mesh/src/alloc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,7 @@ pub(crate) mod testing {

#[macro_export]
macro_rules! alloc_test_suite {
($allocator:expr_2021) => {
($allocator:expr) => {
#[tokio::test]
async fn test_allocator_basic() {
$crate::alloc::testing::test_allocator_basic($allocator).await;
Expand Down
2 changes: 1 addition & 1 deletion hyperactor_mesh/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ mod tests {
use ndslice::selection::Selection;

macro_rules! assert_round_trip_match {
($left:expr_2021, $right:expr_2021) => {{
($left:expr, $right:expr) => {{
assert_structurally_eq!($left, $right);
assert_round_trip!($left);
assert_round_trip!($right);
Expand Down
16 changes: 8 additions & 8 deletions hyperactor_telemetry/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ pub fn swap_telemetry_clock(clock: impl TelemetryClock + Send + 'static) {
/// so MY_COUNTER.add(42, &[key_value!("key", "value")]) and MY_COUNTER.add(42, &[key_value!("key", "other_value")]) will actually bump two separete counters.
#[macro_export]
macro_rules! key_value {
($key:expr_2021, $val:expr_2021) => {
($key:expr, $val:expr) => {
$crate::opentelemetry::KeyValue::new(
$crate::opentelemetry::Key::new($key),
$crate::opentelemetry::Value::from($val),
Expand All @@ -183,7 +183,7 @@ macro_rules! key_value {
/// ```
#[macro_export]
macro_rules! kv_pairs {
($($k:expr_2021 => $v:expr_2021),* $(,)?) => {
($($k:expr => $v:expr),* $(,)?) => {
&[$($crate::key_value!($k, $v),)*]
};
}
Expand Down Expand Up @@ -260,7 +260,7 @@ impl<'a> Drop for TimerGuard<'a> {
/// ```
#[macro_export]
macro_rules! declare_static_timer {
($name:ident, $key:expr_2021, $unit:path) => {
($name:ident, $key:expr, $unit:path) => {
#[doc = "a global histogram timer named: "]
#[doc = $key]
pub static $name: std::sync::LazyLock<$crate::Timer> = std::sync::LazyLock::new(|| {
Expand Down Expand Up @@ -298,7 +298,7 @@ macro_rules! declare_static_timer {
/// ```
#[macro_export]
macro_rules! declare_static_counter {
($name:ident, $key:expr_2021) => {
($name:ident, $key:expr) => {
#[doc = "a global counter named: "]
#[doc = $key]
pub static $name: std::sync::LazyLock<opentelemetry::metrics::Counter<u64>> =
Expand Down Expand Up @@ -329,7 +329,7 @@ macro_rules! declare_static_counter {
/// ```
#[macro_export]
macro_rules! declare_static_up_down_counter {
($name:ident, $key:expr_2021) => {
($name:ident, $key:expr) => {
#[doc = "a global up down counter named: "]
#[doc = $key]
pub static $name: std::sync::LazyLock<opentelemetry::metrics::UpDownCounter<i64>> =
Expand Down Expand Up @@ -364,7 +364,7 @@ macro_rules! declare_static_up_down_counter {
/// ```
#[macro_export]
macro_rules! declare_static_gauge {
($name:ident, $key:expr_2021) => {
($name:ident, $key:expr) => {
#[doc = "a global gauge named: "]
#[doc = $key]
pub static $name: std::sync::LazyLock<opentelemetry::metrics::Gauge<f64>> =
Expand All @@ -390,7 +390,7 @@ macro_rules! declare_static_gauge {
/// ```
#[macro_export]
macro_rules! declare_observable_gauge {
($name:ident, $key:expr_2021, $cb:expr_2021) => {
($name:ident, $key:expr, $cb:expr) => {
#[doc = "a global gauge named: "]
#[doc = $key]
pub static $name: std::sync::LazyLock<opentelemetry::metrics::ObservableGauge<f64>> =
Expand Down Expand Up @@ -425,7 +425,7 @@ macro_rules! declare_observable_gauge {
/// ```
#[macro_export]
macro_rules! declare_static_histogram {
($name:ident, $key:expr_2021) => {
($name:ident, $key:expr) => {
#[doc = "a global histogram named: "]
#[doc = $key]
pub static $name: std::sync::LazyLock<opentelemetry::metrics::Histogram<f64>> =
Expand Down
2 changes: 1 addition & 1 deletion ndslice/src/reshape.rs
Original file line number Diff line number Diff line change
Expand Up @@ -402,7 +402,7 @@ mod tests {
// coordinate systems.
#[macro_export]
macro_rules! assert_layout_preserved {
($original:expr_2021, $reshaped:expr_2021) => {{
($original:expr, $reshaped:expr) => {{
// Iterate over all coordinates in the original slice.
for coord in $original.dim_iter($original.num_dim()) {
let forward = to_reshaped_coord($original, &$reshaped);
Expand Down
6 changes: 3 additions & 3 deletions ndslice/src/selection.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1421,18 +1421,18 @@ where
/// [`selection_from`]: crate::selection::selection_from
#[macro_export]
macro_rules! sel_from_shape {
($shape:expr_2021, $label:ident = $range:expr_2021) => {
($shape:expr, $label:ident = $range:expr) => {
$crate::selection::selection_from_one($shape, stringify!($label), $range).unwrap()
};

($shape:expr_2021, $($label:ident = $val:literal),* $(,)?) => {
($shape:expr, $($label:ident = $val:literal),* $(,)?) => {
$crate::selection::selection_from($shape,
&[
$((stringify!($label), $val..$val+1)),*
]).unwrap()
};

($shape:expr_2021, $($label:ident = $range:expr_2021),* $(,)?) => {
($shape:expr, $($label:ident = $range:expr),* $(,)?) => {
$crate::selection::selection_from($shape, &[
$((stringify!($label), $range)),*
]).unwrap()
Expand Down
2 changes: 1 addition & 1 deletion ndslice/src/selection/parse.rs
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,7 @@ mod tests {

#[macro_export]
macro_rules! assert_parses_to {
($input:expr_2021, $expected:expr_2021) => {{
($input:expr, $expected:expr) => {{
let actual = $crate::selection::parse::tests::parse($input);
$crate::assert_structurally_eq!($expected, actual);
}};
Expand Down
8 changes: 4 additions & 4 deletions ndslice/src/selection/routing.rs
Original file line number Diff line number Diff line change
Expand Up @@ -894,7 +894,7 @@ mod tests {
/// assert_routing_eq_with!(slice, selection, collect_routed_nodes);
/// ```
macro_rules! assert_routing_eq_with {
($slice:expr_2021, $sel:expr_2021, $collector:expr_2021) => {{
($slice:expr, $sel:expr, $collector:expr) => {{
let sel = $sel;
let slice = $slice.clone();
let mut expected: Vec<_> = sel.eval(&EvalOpts::lenient(), &slice).unwrap().collect();
Expand All @@ -908,15 +908,15 @@ mod tests {
/// Asserts that `collect_routed_nodes` matches `Selection::eval`
/// on the given slice.
macro_rules! assert_collect_routed_nodes_eq {
($slice:expr_2021, $sel:expr_2021) => {
($slice:expr, $sel:expr) => {
assert_routing_eq_with!($slice, $sel, collect_routed_nodes)
};
}

/// Asserts that CommActor routing delivers to the same nodes as
/// `Selection::eval`.
macro_rules! assert_commactor_routing_eq {
($slice:expr_2021, $sel:expr_2021) => {
($slice:expr, $sel:expr) => {
assert_routing_eq_with!($slice, $sel, |s, sl| {
collect_commactor_routing_tree(s, sl)
.delivered
Expand All @@ -934,7 +934,7 @@ mod tests {
/// (`collect_commactor_routing_tree`) against the expected output
/// from `Selection::eval`.
macro_rules! assert_all_routing_strategies_eq {
($slice:expr_2021, $sel:expr_2021) => {
($slice:expr, $sel:expr) => {
assert_collect_routed_nodes_eq!($slice, $sel);
assert_commactor_routing_eq!($slice, $sel);
};
Expand Down
4 changes: 2 additions & 2 deletions ndslice/src/selection/test_utils.rs
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ pub fn parse(input: &str) -> Selection {

#[macro_export]
macro_rules! assert_structurally_eq {
($expected:expr_2021, $actual:expr_2021) => {{
($expected:expr, $actual:expr) => {{
let expected = &$expected;
let actual = &$actual;
assert!(
Expand All @@ -46,7 +46,7 @@ macro_rules! assert_structurally_eq {

#[macro_export]
macro_rules! assert_round_trip {
($selection:expr_2021) => {{
($selection:expr) => {{
let selection: Selection = $selection; // take ownership
// Convert `Selection` to representation as compact
// syntax.
Expand Down
6 changes: 3 additions & 3 deletions ndslice/src/shape.rs
Original file line number Diff line number Diff line change
Expand Up @@ -275,7 +275,7 @@ impl fmt::Display for Shape {
/// ```
#[macro_export]
macro_rules! shape {
( $( $label:ident = $size:expr_2021 ),* $(,)? ) => {
( $( $label:ident = $size:expr ),* $(,)? ) => {
{
let mut labels = Vec::new();
let mut sizes = Vec::new();
Expand Down Expand Up @@ -303,11 +303,11 @@ macro_rules! shape {
/// ```
#[macro_export]
macro_rules! select {
($shape:ident, $label:ident = $range:expr_2021) => {
($shape:ident, $label:ident = $range:expr) => {
$shape.select(stringify!($label), $range)
};

($shape:ident, $label:ident = $range:expr_2021, $($labels:ident = $ranges:expr_2021),+) => {
($shape:ident, $label:ident = $range:expr, $($labels:ident = $ranges:expr),+) => {
$shape.select(stringify!($label), $range).and_then(|shape| $crate::select!(shape, $($labels = $ranges),+))
};
}
Expand Down
2 changes: 1 addition & 1 deletion ndslice/src/view.rs
Original file line number Diff line number Diff line change
Expand Up @@ -637,7 +637,7 @@ impl<T: Viewable> ViewExt for T {
/// ```
#[macro_export]
macro_rules! extent {
( $( $label:ident = $size:expr_2021 ),* $(,)? ) => {
( $( $label:ident = $size:expr ),* $(,)? ) => {
{
let mut labels = Vec::new();
let mut sizes = Vec::new();
Expand Down
4 changes: 2 additions & 2 deletions torch-sys/src/ivalue.rs
Original file line number Diff line number Diff line change
Expand Up @@ -503,7 +503,7 @@ mod tests {
}

macro_rules! generate_py_object_roundtrip_tests {
($($kind:ident, $input:expr_2021);* $(;)?) => {
($($kind:ident, $input:expr);* $(;)?) => {
paste! {
$(
#[test]
Expand Down Expand Up @@ -552,7 +552,7 @@ mod tests {
}

macro_rules! generate_serde_roundtrip_tests {
($($kind:ident, $input:expr_2021);* $(;)?) => {
($($kind:ident, $input:expr);* $(;)?) => {
paste! {
$(
#[test]
Expand Down
Loading