scheduler.py 文件源码

def __init__(self, file_path):
        """
        Args:
            file_path: is the location of where the filesystem based lockfile should be written to.
        """
        self._fs_lock = defer.DeferredFilesystemLock(file_path)
        self._mutex = defer.DeferredLock()