Skip to content

Commit 32534f7

Browse files
updated executor
1 parent f6ee03b commit 32534f7

2 files changed

Lines changed: 5 additions & 2 deletions

File tree

taskflow/core/executor.hpp

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -723,6 +723,11 @@ inline void Executor::_sync_topology(Topology& tpg) {
723723

724724
auto &f = tpg._taskflow;
725725

726+
// TODO: check whether we can use tpg instead of t._topologies.front()
727+
// below and elsewhere.
728+
729+
assert(&tpg == &(f._topologies.front()));
730+
726731
// case 1: we still need to run the topology again
727732
if(!std::invoke(f._topologies.front()._pred)) {
728733
f._topologies.front()._recover_num_sinks();

unittest/taskflow.cpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -443,8 +443,6 @@ TEST_CASE("ParallelForOnIndex" * doctest::timeout(300)) {
443443
using namespace std::chrono_literals;
444444

445445
auto exception_test = [] (unsigned num_workers) {
446-
447-
tf::Executor executor(num_workers);
448446
tf::Taskflow tf;
449447

450448
// invalid index

0 commit comments

Comments
 (0)