Use cancel instead of finish in case of exception

src/Processors/Executors/PipelineExecutor.cpp

@@ -391,26 +391,17 @@ void PipelineExecutor::executeImpl(size_t num_threads, bool concurrency_control)
     SCOPE_EXIT_SAFE(
         if (!finished_flag)
         {
-            finish();
+            /// If finished_flag is not set, there was an exception.
+            /// Cancel execution in this case.
+            cancel();
             if (pool)
                 pool->wait();
         }
     );
 
     if (num_threads > 1)
     {
-        try
-        {
-            spawnThreads(); // start at least one thread
-        }
-        catch (...)
-        {
-            /// spawnThreads can throw an exception, for example CANNOT_SCHEDULE_TASK.
-            /// We should cancel execution properly before rethrow.
-            cancel();
-            throw;
-        }
-
+        spawnThreads(); // start at least one thread
         tasks.processAsyncTasks();
         pool->wait();
     }