We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 558fc5a commit 2facd98Copy full SHA for 2facd98
cpp/src/arrow/dataset/dataset_writer.cc
@@ -383,8 +383,11 @@ class DatasetWriterDirectoryQueue
383
}
384
init_future_ = Future<>::Make();
385
auto create_dir_cb = [this] {
386
- return DeferNotOk(write_options_.filesystem->io_context().executor()->Submit(
387
- [this]() { return write_options_.filesystem->CreateDir(directory_, write_options_.create_dir); }));
+ return DeferNotOk(
+ write_options_.filesystem->io_context().executor()->Submit([this]() {
388
+ return write_options_.filesystem->CreateDir(directory_,
389
+ write_options_.create_dir);
390
+ }));
391
};
392
// We need to notify waiters whether the directory succeeded or failed.
393
auto notify_waiters_cb = [this] { init_future_.MarkFinished(); };
0 commit comments