Server

class Server(comm: InetSocketAddress, logs: InetSocketAddress)

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

Constructors

constructor(comm: InetSocketAddress, logs: InetSocketAddress)

fun serve(bundle: Bundle)

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

suspend fun serveAsync(bundle: Bundle): Job

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