Server

sealed class Server

Connects this JVM process to the Airflow coordinator and dispatches task execution requests to the registered Bundle.

The typical entry point is:

public static void main(String[] args) {
    Server.create(args).serve(new MyBundleBuilder().build());
}

The process exits when the coordinator closes the connection (normally after one task-instance execution).

Types

fun serve(bundle: Bundle)

Blocking entry point: connects to the coordinator and serves task-execution requests from the given bundle.

abstract suspend fun serveAsync(bundle: Bundle)

Suspending entry point: connects to the coordinator and serves task-execution requests from the given bundle.