AIPseudo.py

# COLLECT / TRAIN
from skycatch import drone, ai
async def run():
  try:
    collection = 
      await drone.runCollection()
      await 
        ai.train.labeling_queue(collection.data)
  except Exception as exc:
    print('Internal collection ' 
          'error: {!r}'.format(exc))
 
# INSPECT / ACT
from skycatch import drone, api, ai
async def run():
  try:
    collection = 
      await drone.runInspection()
    inferences = 
      await ai.infer(inspection.data)
    # customer workflow API, callback
    api.callback(inferences) 
  except Exception as exc:
      print('Internal inspection '  
            'error: {!r}'.format(exc))