Module runtime

re-export of datafusion_common_runtime crate

Modules

common

Structs

JoinSet

A wrapper around Tokio’s JoinSet that forwards all API calls while optionally instrumenting spawned tasks and blocking closures with custom tracing behavior. If no tracer is injected via trace_utils::set_tracer, tasks and closures are executed without any instrumentation.

SpawnedTask

Helper that provides a simple API to spawn a single task and join it. Provides guarantees of aborting on Drop to keep it cancel-safe. Note that if the task was spawned with spawn_blocking, it will only be aborted if it hasn’t started yet.

Traits

JoinSetTracer

A trait for injecting instrumentation into either asynchronous futures or blocking closures at runtime.

Functions

set_join_set_tracer

Set the custom tracer for both futures and blocking closures.