Skip to content

Commit

Permalink
remove one more runwithcapturedr
Browse files Browse the repository at this point in the history
  • Loading branch information
paleolimbot committed Aug 1, 2022
1 parent a5a5011 commit db12bff
Showing 1 changed file with 2 additions and 8 deletions.
10 changes: 2 additions & 8 deletions r/src/compute-exec.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -372,14 +372,8 @@ void ExecPlan_Write(
ds::WriteNodeOptions{std::move(opts), std::move(kv)});

StopIfNotOk(plan->Validate());

arrow::Status result = RunWithCapturedRIfPossibleVoid([&plan]() {
RETURN_NOT_OK(plan->StartProducing());
RETURN_NOT_OK(plan->finished().status());
return arrow::Status::OK();
});

StopIfNotOk(result);
StopIfNotOk(plan->StartProducing());
StopIfNotOk(plan->finished().status());
}

#endif
Expand Down

0 comments on commit db12bff

Please sign in to comment.