Skip to content

Commit 54c27bd

Browse files
committed
fix: typo
1 parent 368a83e commit 54c27bd

File tree

3 files changed

+2
-3
lines changed

3 files changed

+2
-3
lines changed

src/experimaestro/connectors/local.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ def start(self, task_mode=False):
147147

148148
class InterProcessLock(FastenersInterProcessLock, Lock):
149149
def __init__(self, path, max_delay=-1):
150-
InterProcessLock.__init__(self, path)
150+
FastenersInterProcessLock.__init__(self, path)
151151
self.max_delay = max_delay
152152

153153
def __enter__(self):

src/experimaestro/connectors/ssh.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
import io
1010
import os
1111
import re
12+
from asyncio import Lock
1213
from experimaestro.launcherfinder import LauncherRegistry
1314
from urllib.parse import urlparse
1415
from itertools import chain
@@ -19,7 +20,6 @@
1920
RedirectType,
2021
Redirect,
2122
)
22-
from experimaestro.locking import Lock
2323
from experimaestro.tokens import Token
2424

2525
try:

src/experimaestro/scheduler/jobs.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -309,7 +309,6 @@ async def aio_start(self, sched_dependency_lock, notification_server=None):
309309

310310
async with Locks() as locks:
311311
logger.debug("[starting] Locking job %s", self)
312-
# async with self.launcher.connector.lock(self.lockpath):
313312
with self.launcher.connector.lock(self.lockpath):
314313
logger.debug("[starting] Locked job %s", self)
315314

0 commit comments

Comments
 (0)