def main():
    with example_utils.get_backend() as backend:
        logbooks = list(backend.get_connection().get_logbooks())
        for lb in logbooks:
            for fd in lb:
                if fd.state not in FINISHED_STATES:
                    resume(fd, backend)
dataset/ETHPy150Open openstack/taskflow/taskflow/examples/resume_many_flows/resume_all.py/main/original