From 668bea876da3015ad13ff4c4cc53cb0e96a60c3c Mon Sep 17 00:00:00 2001 From: Rob Nagler <5495179+robnagler@users.noreply.github.com> Date: Sun, 22 Dec 2024 22:41:59 +0000 Subject: [PATCH] fmt --- sirepo/job_driver/__init__.py | 4 +++- sirepo/job_driver/sbatch.py | 1 - 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/sirepo/job_driver/__init__.py b/sirepo/job_driver/__init__.py index a01800e5fa..6d4a8557d3 100644 --- a/sirepo/job_driver/__init__.py +++ b/sirepo/job_driver/__init__.py @@ -324,7 +324,9 @@ def _agent_receive_alive(self, msg): if self._websocket: if self._websocket != msg.handler: self._websocket = None - raise AssertionError(pkdformat("unexpected incoming msg.content={}", msg.content)) + raise AssertionError( + pkdformat("unexpected incoming msg.content={}", msg.content) + ) else: self._websocket = msg.handler self._websocket_ready.set() diff --git a/sirepo/job_driver/sbatch.py b/sirepo/job_driver/sbatch.py index f0c73aef38..f3864c6ad8 100644 --- a/sirepo/job_driver/sbatch.py +++ b/sirepo/job_driver/sbatch.py @@ -70,7 +70,6 @@ async def kill(self): except Exception as e: pkdlog("{} error={} stack={}", self, e, pkdexc()) - @classmethod def get_instance(cls, op): u = op.msg.uid