fairseq/logging/metrics.py

Survived

Mutant 1205

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -24,7 +24,7 @@
 # created by the :func:`aggregate` context manager.
 _aggregators = OrderedDict()
 _active_aggregators = OrderedDict()
-_active_aggregators_cnt = defaultdict(lambda: 0)
+_active_aggregators_cnt = defaultdict(lambda: 1)
 
 
 def reset() -> None:

Mutant 1206

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -24,7 +24,7 @@
 # created by the :func:`aggregate` context manager.
 _aggregators = OrderedDict()
 _active_aggregators = OrderedDict()
-_active_aggregators_cnt = defaultdict(lambda: 0)
+_active_aggregators_cnt = defaultdict(lambda: None)
 
 
 def reset() -> None:

Mutant 1209

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -34,7 +34,7 @@
     _active_aggregators_cnt.clear()
 
     # The "default" aggregator observes all logged values.
-    _aggregators["default"] = MetersDict()
+    _aggregators["default"] = None
     _active_aggregators["default"] = _aggregators["default"]
     _active_aggregators_cnt["default"] = 1
 

Mutant 1210

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -35,7 +35,7 @@
 
     # The "default" aggregator observes all logged values.
     _aggregators["default"] = MetersDict()
-    _active_aggregators["default"] = _aggregators["default"]
+    _active_aggregators["XXdefaultXX"] = _aggregators["default"]
     _active_aggregators_cnt["default"] = 1
 
 

Mutant 1212

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -35,7 +35,7 @@
 
     # The "default" aggregator observes all logged values.
     _aggregators["default"] = MetersDict()
-    _active_aggregators["default"] = _aggregators["default"]
+    _active_aggregators["default"] = None
     _active_aggregators_cnt["default"] = 1
 
 

Mutant 1213

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -36,7 +36,7 @@
     # The "default" aggregator observes all logged values.
     _aggregators["default"] = MetersDict()
     _active_aggregators["default"] = _aggregators["default"]
-    _active_aggregators_cnt["default"] = 1
+    _active_aggregators_cnt["XXdefaultXX"] = 1
 
 
 reset()

Mutant 1214

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -36,7 +36,7 @@
     # The "default" aggregator observes all logged values.
     _aggregators["default"] = MetersDict()
     _active_aggregators["default"] = _aggregators["default"]
-    _active_aggregators_cnt["default"] = 1
+    _active_aggregators_cnt["default"] = 2
 
 
 reset()

Mutant 1215

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -36,7 +36,7 @@
     # The "default" aggregator observes all logged values.
     _aggregators["default"] = MetersDict()
     _active_aggregators["default"] = _aggregators["default"]
-    _active_aggregators_cnt["default"] = 1
+    _active_aggregators_cnt["default"] = None
 
 
 reset()

Mutant 1216

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -41,8 +41,6 @@
 
 reset()
 
-
-@contextlib.contextmanager
 def aggregate(name: Optional[str] = None, new_root: bool = False):
     """Context manager to aggregate metrics under a given name.
 

Mutant 1217

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -43,7 +43,7 @@
 
 
 @contextlib.contextmanager
-def aggregate(name: Optional[str] = None, new_root: bool = False):
+def aggregate(name: Optional[str] = None, new_root: bool = True):
     """Context manager to aggregate metrics under a given name.
 
     Aggregations can be nested. If *new_root* is ``False``, then logged

Mutant 1218

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -132,7 +132,7 @@
         agg[key].update(value, weight)
 
 
-def log_derived(key: str, fn: Callable[[MetersDict], float], priority: int = 20):
+def log_derived(key: str, fn: Callable[[MetersDict], float], priority: int = 21):
     """Log a scalar value derived from other meters.
 
     Args:

Mutant 1219

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -168,7 +168,7 @@
             agg[key].update(value)
 
 
-def log_start_time(key: str, priority: int = 40, round: Optional[int] = None):
+def log_start_time(key: str, priority: int = 41, round: Optional[int] = None):
     """Log the duration of some event in seconds.
 
     The duration will be computed once :func:`log_stop_time` is called.

Mutant 1220

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -184,7 +184,7 @@
         agg[key].start()
 
 
-def log_stop_time(key: str, weight: float = 0., prehook=None):
+def log_stop_time(key: str, weight: float = 1.0, prehook=None):
     """Log the duration of some event in seconds.
 
     The duration will be computed since :func:`log_start_time` was called.

Mutant 1221

--- fairseq/logging/metrics.py
+++ fairseq/logging/metrics.py
@@ -206,7 +206,7 @@
     new_meter_fn: Callable[[], Meter],
     key: str,
     *args,
-    priority: int = 50,
+    priority: int = 51,
     **kwargs,
 ):
     """Log using a custom Meter.