From a38f68de5124faa6cfabbb248e604eb037ab1b63 Mon Sep 17 00:00:00 2001 From: Michael Woods Date: Sun, 16 Feb 2025 11:36:39 -0500 Subject: [PATCH] Bugfixes to quick. --- src/packetserver/client/__init__.py | 7 ++++--- src/packetserver/client/jobs.py | 2 +- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/packetserver/client/__init__.py b/src/packetserver/client/__init__.py index f5bfb29..0999d0d 100644 --- a/src/packetserver/client/__init__.py +++ b/src/packetserver/client/__init__.py @@ -91,9 +91,10 @@ class Client: with self.lock_locker: if dest.upper() not in self._connection_locks: self._connection_locks[dest.upper()] = Lock() - conn = self.connection_callsign(dest.upper()) - if conn is not None: - return conn + with self._connection_locks[dest.upper()]: + conn = self.connection_callsign(dest.upper()) + if conn is not None: + return conn conn = self.app.open_connection(0, self.callsign, dest.upper()) while conn.state.name != "CONNECTED": diff --git a/src/packetserver/client/jobs.py b/src/packetserver/client/jobs.py index 42c8645..52b3f7b 100644 --- a/src/packetserver/client/jobs.py +++ b/src/packetserver/client/jobs.py @@ -148,7 +148,7 @@ class JobSession: def run_job(self, cmd: Union[str, list], db: bool = False, env: dict = None, files: dict = None, quick: bool = False) -> JobWrapper: if quick: - j = send_job_quick(cmd, db=db, env=env, files=files) + j = self.send_quick(cmd, db=db, env=env, files=files) self.job_log.append(j) return j else: