Massive Parallel Tasks

import sys

sys.path.append('../python') # path to beecluster

import beecluster

# test non-same drone but non-interruptible

def visit(bc, loc):

bc.act("flyto", loc)

bc.wait()

if __name__ == "__main__":

bc = beecluster.Session(appID = "TEST-4")

handles = []

for x in range(-50,51,10):

for y in range(-50,51,10):

h = bc.newTask(visit, bc, (x,y,30), TaskName="visit")

handles.append(h)

results = [h.wait() for h in handles]

bc.close(SaveDTG=False)