choose

abstract fun choose(context: Context, client: Client): Class<out Task>

Chooses the one case that runs.

Any exception thrown marks the task instance as failed, and nothing is then pushed or skipped.

The class of one of this switch's cases.

context

Runtime context for the current execution workload.

client

Client for Airflow API calls scoped to this execution.

on failure; the task instance is marked failed.