def interrupt_trigger_iter(fg):
    for f in fg:
        if (not interrupt_trigger[0]):
            break
        (yield f)
def interrupt_trigger_iter(fg):
    for f in fg:
        if (not interrupt_trigger[0]):
            break
        (yield f)