def create()

in nuvolaris/cronjob.py [0:0]

• 30 lines of code
• 9 McCabe index (conditional complexity)

def create(owner=None):
    logging.info("creating cron")
    
    img = cfg.get('operator.image') or "missing-operator-image"
    tag = cfg.get('operator.tag') or "missing-operator-tag"
    image = f"{img}:{tag}"
    logging.info(f"cron using image {image}")

    #default to every minutes if not configured
    schedule = cfg.get('scheduler.schedule') or "* * * * *"
    config = {
        "scheduler.schedule":schedule,
        "controller.protocol":cfg.get('controller.protocol') or "http",
        "controller.host":cfg.get('controller.host') or "controller",
        "controller.port":cfg.get('controller.port') or "3233",
        "couchdb.controller.user":cfg.get('couchdb.controller.user'),
        "couchdb.controller.password":cfg.get('couchdb.controller.password')
    }

    data = {
        "image": image,
        "schedule": schedule,
        "config": json.dumps(config),
        "name": "cron"
    }
    
    kust = kus.patchTemplate("scheduler", "cron-init.yaml", data)    
    spec = kus.kustom_list("scheduler", kust, templates=[], data=data)

    if owner:
        kopf.append_owner_reference(spec['items'], owner)
    else:
        cfg.put("state.cron.spec", spec)

    res = kube.apply(spec)
    logging.info(f"create cron: {res}")
    return res