serveAsync

suspend fun serveAsync(bundle: Bundle): Job

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

Opens both the task-execution channel (--comm) and the log-forwarding channel (--logs) concurrently, then processes incoming requests until the coordinator closes the connection (normally after one task-instance execution). The coroutine returns once both channels have been closed.

Use this variant when calling from an existing coroutine scope; use the blocking serve from a plain main method.

Parameters

bundle

Bundle containing all Dags this process can execute.

See also