message: init global source state before calling continue in loop ... oops
diff: @@ -117,6 +117,13 @@ void Executor::SchedulePipeline(const shared_ptr<MetaPipeline> &meta_pipeline, S
  // set up the dependencies within this MetaPipeline
  for (auto &pipeline : pipelines) {
  + auto source = pipeline->GetSource();
  + if (source->type == PhysicalOperatorType::TABLE_SCAN) {
  + // we have to reset the source here (in the main thread), because some of our clients (looking at you, R)
  + // do not like it when threads other than the main thread call into R, for e.g., arrow scans
  + pipeline->ResetSource(true);
  + }
  +
  auto dependencies = meta_pipeline->GetDependencies(pipeline.get());
  if (!dependencies) {
  continue;
  @@ -126,13 +133,6 @@ void Executor::SchedulePipeline(const shared_ptr<MetaPipeline> &meta_pipeline, S
  auto &dependency_stack = event_map[dependency];
  pipeline_stack.pipeline_event->AddDependency(*dependency_stack.pipeline_event);
  }
  -
  - auto source = pipeline->GetSource();
  - if (source->type == PhysicalOperatorType::TABLE_SCAN) {
  - // we have to reset the source here (in the main thread), because some of our clients (looking at you, R)
  - // do not like it when threads other than the main thread call into R, for e.g., arrow scans
  - pipeline->ResetSource(true);
  - }
  }
  }
  