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 and are defined through the @task decorator.

from seaplane import task

@task(id='my-task')
def my_task(context)
    # run your task code here

The contect 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.

Context

The task context is used to retrieve input from the DAG or application entrypoint and generate output for the next task in the DAG or the application exit point. You can learn more about task context here.