execute

open override fun execute(context: Context, client: Client)

Resolves this task's declared input, then runs execute. Implementations override the three-argument execute instead of this method.


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

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 execution.

input

This task's arguments, as bound at the stub call site.

Throws

on failure; the task instance is marked failed.