Change log level for Compute Failed log message (#8802)

dask · Jul 30, 2024 · 5e1d365 · 5e1d365
1 parent 386e5fe
commit 5e1d365
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/distributed/tests/test_worker.py b/distributed/tests/test_worker.py
@@ -171,9 +171,9 @@ def reset(self):
 
     tb = await y._traceback()
     assert any("1 / 0" in line for line in pluck(3, traceback.extract_tb(tb)) if line)
-    assert "Compute Failed" in hdlr.messages["warning"][0]
-    assert y.key in hdlr.messages["warning"][0]
-    assert "executing" in hdlr.messages["warning"][0]
+    assert "Compute Failed" in hdlr.messages["error"][0]
+    assert y.key in hdlr.messages["error"][0]
+    assert "executing" in hdlr.messages["error"][0]
     logger.setLevel(old_level)
 
     # Now we check that both workers are still alive.

diff --git a/distributed/worker.py b/distributed/worker.py
@@ -2341,7 +2341,7 @@ async def execute(self, key: Key, *, stimulus_id: str) -> StateMachineEvent:
                 )
 
             if ts.state in ("executing", "long-running", "resumed"):
-                logger.warning(
+                logger.error(
                     "Compute Failed\n"
                     "Key:       %s\n"
                     "State:     %s\n"