diff --git a/distributed/deploy/adaptive_core.py b/distributed/deploy/adaptive_core.py index b15aa49634..b74e013c94 100644 --- a/distributed/deploy/adaptive_core.py +++ b/distributed/deploy/adaptive_core.py @@ -201,7 +201,8 @@ async def adapt(self) -> None: await self.scale_up(**recommendations) if status == "down": await self.scale_down(**recommendations) - except OSError: + except OSError as e: + logger.error("Adaptive stopping due to error %s", str(e)) self.stop() finally: self._adapting = False