| 127 | |
| 128 | #ifdef ARROW_WITH_OPENTELEMETRY |
| 129 | ::arrow::internal::tracing::Scope TraceTaskSubmitted(AsyncTaskScheduler::Task* task, |
| 130 | const util::tracing::Span& parent) { |
| 131 | if (task->span.valid()) { |
| 132 | EVENT(task->span, "task submitted"); |
| 133 | return ACTIVATE_SPAN(task->span); |
| 134 | } |
| 135 | |
| 136 | return START_SCOPED_SPAN_WITH_PARENT_SV(task->span, parent, task->name(), |
| 137 | {{"task.cost", task->cost()}}); |
| 138 | } |
| 139 | |
| 140 | void TraceTaskQueued(AsyncTaskScheduler::Task* task, const util::tracing::Span& parent) { |
| 141 | START_SCOPED_SPAN_WITH_PARENT_SV(task->span, parent, task->name(), |
no test coverage detected