gistfile1.txt

def get_job_finish_status(phash_id, timeout=100):
    """ Wait for the job to finish or abort if job is unable to finish
    Job status can be one of:
        - QUEUED
        - STARTED
        - DEFERRED
        - FINISHED
        - FAILED
    If the job fails to move from queued, deferred to other states, we will
    timeout (return False) after the given timeout period.
    """

    cycle = 0
    os = ''

    while True:
        job = get_assigned_job(phash_id)

        if job is None:
            return False

        st = job.get_status()

        if st != os:
            cycle = 0
            os = st

        if st == JS.FINISHED:       # TODO: should we check cache paths?
            return True

        if st == JS.FAILED:
            return False

        if st == JS.STARTED:
            cycle = 0

        time.sleep(timeout)     # sleep 10 seconds
        cycle += 10

        if cycle >= timeout:
            break

    return False