diff --git a/rdiff-manager.py b/rdiff-manager.py index 98072af5275ec9b732a58c968255a3d6c9e4942d..faf8cec864717c5129a5cb0c5f664c62d90565aa 100755 --- a/rdiff-manager.py +++ b/rdiff-manager.py @@ -81,7 +81,10 @@ if __name__ == '__main__': concurrent_num = len(hosts) pool = Pool(concurrent_num) + # Start the work and wait for it to finish results = [ (host, pool.apply_async(rdiff_backup, (host, )) ) for host in hosts ] + pool.close() + pool.join() for host, r in results: print("Backup results for", host['hostname'])