from pipeline.engine import PipelineEngine

ENGINE = None


def init_engine(nodes):
    global ENGINE
    ENGINE = PipelineEngine(nodes)


def get_state():
    return ENGINE.last_results if ENGINE else []


def retry_action(data):
    return {"status": "retry", "action": data["action"]}


def force_node(data):
    return {
        "status": "forced",
        "action": data["action"],
        "node": data["node"]
    }


def pause():
    return {"status": "paused"}


def resume():
    return {"status": "running"}