comments

Author: alamb

datafusion-examples/examples/thread_pools_lib/dedicated_executor.rs

@@ -16,10 +16,7 @@
 // under the License.
 
 //! [DedicatedExecutor] for running CPU-bound tasks on a separate tokio runtime.
-//!
-//! Originally from [InfluxDB 3.0]
-//!
-//! [InfluxDB 3.0]: https://github.com/influxdata/influxdb3_core/tree/6fcbb004232738d55655f32f4ad2385523d10696/executor
+
 use crate::SendableRecordBatchStream;
 use async_trait::async_trait;
 use datafusion::physical_plan::stream::RecordBatchStreamAdapter;
@@ -128,6 +125,11 @@ impl From<Builder> for DedicatedExecutorBuilder {
 /// drop a runtime in a context where blocking is not allowed it means  This
 /// happens when a runtime is dropped from within an asynchronous
 /// context.', .../tokio-1.4.0/src/runtime/blocking/shutdown.rs:51:21
+///
+/// # Notes
+/// This code is derived from code originally written for [InfluxDB 3.0]
+///
+/// [InfluxDB 3.0]: https://github.com/influxdata/influxdb3_core/tree/6fcbb004232738d55655f32f4ad2385523d10696/executor
 #[derive(Clone, Debug)]
 pub struct DedicatedExecutor {
     /// State for managing Tokio Runtime Handle for CPU tasks