diff --git a/continuous_integration/scripts/test_report.py b/continuous_integration/scripts/test_report.py index 1f339ed7ef..1f749a78fd 100644 --- a/continuous_integration/scripts/test_report.py +++ b/continuous_integration/scripts/test_report.py @@ -489,7 +489,7 @@ def main(argv: list[str] | None = None) -> None: total.groupby([total.file, total.test]) .filter(lambda g: (g.status == "x").sum() >= args.nfails) .reset_index() - .assign(test=lambda df: df.file + "." + df.test) + .assign(test=lambda df: df.file + "." + df.test) # type: ignore .groupby("test") ) overall = {name: grouped.get_group(name) for name in grouped.groups} diff --git a/distributed/worker_memory.py b/distributed/worker_memory.py index e0ac5dde12..4f0c75d499 100644 --- a/distributed/worker_memory.py +++ b/distributed/worker_memory.py @@ -417,6 +417,7 @@ def memory_monitor(self, nanny: Nanny) -> None: except (ProcessLookupError, psutil.NoSuchProcess, psutil.AccessDenied): return # pragma: nocover + assert self.memory_limit if memory / self.memory_limit <= self.memory_terminate_fraction: return