What is a task?

This document describes the function of tasks inside the Seaplane platform and how to use them.

Tasks are the building blocks inside Seaplane applications. A task definition is a python function that takes in a msg object:

def my_task(msg)
    # write your task code here

Message (msg)

The msg object inside the function definition holds the input data that is retrieved from the previous step in your pipeline (DAG) or the application entry point. Using this input data, the task generates an output for the next task in the DAG or for the application exit point. Learn more about task msg here.