alienhunter/packetserver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Bugfixes to quick.

Browse Source
This commit is contained in:
Michael Woods
2025-02-16 11:36:39 -05:00
parent 6231711e8f
commit a38f68de51
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/packetserver/client/__init__.py
View File

@@ -91,6 +91,7 @@ class Client:
with self.lock_locker: with self.lock_locker:
if dest.upper() not in self._connection_locks: if dest.upper() not in self._connection_locks:
self._connection_locks[dest.upper()] = Lock() self._connection_locks[dest.upper()] = Lock()
with self._connection_locks[dest.upper()]:
conn = self.connection_callsign(dest.upper()) conn = self.connection_callsign(dest.upper())
if conn is not None: if conn is not None:
return conn return conn

2
src/packetserver/client/jobs.py
View File

@@ -148,7 +148,7 @@ class JobSession:
def run_job(self, cmd: Union[str, list], db: bool = False, env: dict = None, files: dict = None, def run_job(self, cmd: Union[str, list], db: bool = False, env: dict = None, files: dict = None,
quick: bool = False) -> JobWrapper: quick: bool = False) -> JobWrapper:
if quick: 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) self.job_log.append(j)
return j return j
else: else: