[skip ci] rebase

kuzudb · Sep 8, 2023 · e5bd0fd · e5bd0fd
1 parent 507013f
commit e5bd0fd
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/src/processor/processor.cpp b/src/processor/processor.cpp
@@ -36,7 +36,7 @@ std::shared_ptr<FactorizedTable> QueryProcessor::execute(
 }
 
 void QueryProcessor::decomposePlanIntoTasks(
-    PhysicalOperator* op, PhysicalOperator* parent, Task* parentTask, ExecutionContext* context) {
+        PhysicalOperator* op, PhysicalOperator* parent, Task* parentTask, ExecutionContext* context) {
     if (op->isSink() && parent != nullptr) {
         auto childTask = std::make_unique<ProcessorTask>(reinterpret_cast<Sink*>(op), context);
         if (op->getOperatorType() == PhysicalOperatorType::AGGREGATE) {
@@ -49,10 +49,6 @@ void QueryProcessor::decomposePlanIntoTasks(
         for (auto i = (int64_t)op->getNumChildren() - 1; i >= 0; --i) {
             decomposePlanIntoTasks(op->getChild(i), op, childTask.get(), context);
         }
-        if (op->getOperatorType() == PhysicalOperatorType::COPY_TO) {
-            childTask->setSingleThreadedTask();
-        }
-        decomposePlanIntoTasks(op->getChild(0), op, childTask.get(), context);
         parentTask->addChildTask(std::move(childTask));
     } else {
         // Schedule the right most side (e.g., build side of the hash join) first.