Build on VAST

def init(ctx):
    # One time initialization
    ctx.logger.info(
        f"Initialized... {os.environ.get('FUNCTION_NAME')}")

def handler(ctx, event):
    # Events processing
    ctx.logger.info(f"Handler {event}")
    # Do stuff with the event :)
    return "Hello VAST"

#build function image
vastde functions build serverlessfunc
Build completed: serverlessfunc: initial

#...push to container registry...

#create function on DataEngine
vastde functions create --name serverlessfunc \ 
--container-registry <registry> \
--artifact-source <registry_user>/serverlessfunc \
--image-tag latest

Function created: serverlessfunc
Description: Basic function that prints : "Hello VAST"

#create a trigger on DataEngine
vastde triggers create -f schedule-trigger.yaml

#...logging...
Trigger created: schedule-1m-trigger
Type: Schedule
Topic: vast:dataengine:topics:vast-workshop-broker/default

#scheduler trigger --> pipeline --> hello vast pipeline

#create a pipeline on DataEngine 
vastde pipelines create --config pipeline-config.yaml

#...logging...
Pipeline created: hello-vast-pipeline