MCPcopy Create free account
hub / github.com/apache/arrow / TraceTaskSubmitted

Function TraceTaskSubmitted

cpp/src/arrow/util/async_util.cc:128–137  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers 1

SubmitTaskUnlockedMethod · 0.85

Calls 3

validMethod · 0.45
nameMethod · 0.45
costMethod · 0.45

Tested by

no test coverage detected