Skip to content

Commit 9da5daf

Browse files
committed
test: add test with num_proc for to_sql function
1 parent 1825a4a commit 9da5daf

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

tests/test_arrow_dataset.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2712,6 +2712,15 @@ def test_to_sql(self, in_memory):
27122712
self.assertEqual(sql_dset.shape, dset.shape)
27132713
self.assertListEqual(list(sql_dset.columns), list(dset.column_names))
27142714

2715+
# Test writing with multiprocessors
2716+
with self._create_dummy_dataset(in_memory, tmp_dir, multiple_columns=True) as dset:
2717+
file_path = os.path.join(tmp_dir, "test_path.sqlite")
2718+
_ = dset.to_sql("data", "sqlite:///" + file_path, num_proc=3, if_exists="replace")
2719+
self.assertTrue(os.path.isfile(file_path))
2720+
sql_dset = pd.read_sql("data", "sqlite:///" + file_path)
2721+
self.assertEqual(sql_dset.shape, dset.shape)
2722+
self.assertListEqual(list(sql_dset.columns), list(dset.column_names))
2723+
27152724
def test_train_test_split(self, in_memory):
27162725
with tempfile.TemporaryDirectory() as tmp_dir:
27172726
with self._create_dummy_dataset(in_memory, tmp_dir) as dset:

0 commit comments

Comments
 (0)