MCPcopy Create free account
hub / github.com/BlazingDB/blazingsql / notify_fail

Method notify_fail

engine/src/execution_kernels/kernel.cpp:117–121  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

115}
116
117void kernel::notify_fail(size_t task_id){
118 std::lock_guard<std::mutex> lock(kernel_mutex);
119 this->tasks.erase(task_id);
120 kernel_cv.notify_one();
121}
122
123// This is only the default estimate of the bytes to be output by a kernel based on the input.
124// Each kernel should implement its own version of this, if its possible to obtain a better estimate

Callers 1

failMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected