def change_status()

in functions/orchestration-helpers/scheduling/main.py [0:0]


def change_status(job_name, new_value):
    """
    evaluates if a cloud scheduler rule must be paused or resumed, depending on firestore trigger

    Args:
        job_name: name for the scheduler job, should be the same as cloud workflows name
        new value:  new firestore value coming in trigger info

    """
    workflow_status = new_value.fields["workflow_status"].string_value
    print(f"workflow_status: {workflow_status} ")
    if workflow_status == 'DISABLED':
        pause_job(job_name)
    if workflow_status == 'ENABLED':
        resume_job(job_name)