execute

abstract fun execute(context: Context, client: Client)

Executes this task.

Any exception thrown marks the task instance as failed. Use client to read connections, variables, pull XComs, or to push an XCom for downstream tasks.

Parameters

context

Runtime context for the current execution workload.

client

Client for Airflow API calls scoped to this exxecution.

Throws

on failure; the task instance is marked failed.