model.py 文件源码

def lock_snapshot_cron_job(snapshot_time):
    """Obtains a lock for a snapshot cron job.

    Args:
        snapshot_time: Timestamp of the snapshot.

    Returns:
        True if a lock is acquired. Otherwise False.
    """
    try:
        _db.cron_locks.insert_one({
            '_id': 'snapshot:%d' % snapshot_time,
            'locked_time': misc_util.time(),
        })
    except pymongo.errors.DuplicateKeyError:
        return False
    return True