File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff 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 ();
Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments