Display unexpected state in Worker.execute validation (#6856)

dask · Aug 9, 2022 · 85cbe45 · 85cbe45
1 parent bf53760
commit 85cbe45
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -2164,7 +2164,7 @@ async def execute(self, key: str, *, stimulus_id: str) -> StateMachineEvent | No
         try:
             if self.state.validate:
                 assert not ts.waiting_for_data
-                assert ts.state == "executing"
+                assert ts.state == "executing", ts.state
                 assert ts.run_spec is not None
 
             args2, kwargs2 = self._prepare_args_for_execution(ts, args, kwargs)