diff --git a/tests/ludwig/data/test_split.py b/tests/ludwig/data/test_split.py index 34eff8085c1..4d663cfd7a3 100644 --- a/tests/ludwig/data/test_split.py +++ b/tests/ludwig/data/test_split.py @@ -168,8 +168,6 @@ def test_datetime_split(df_engine): npartitions = 10 df = pd.DataFrame(np.random.randint(0, 100, size=(nrows, 3)), columns=["A", "B", "C"]) - if isinstance(df_engine, DaskEngine): - df = df_engine.df_lib.from_pandas(df, npartitions=npartitions) def random_date(*args, **kwargs): start = datetime.strptime("1/1/1990 1:30 PM", "%m/%d/%Y %I:%M %p") @@ -181,6 +179,9 @@ def random_date(*args, **kwargs): df["date_col"] = df["C"].map(random_date) + if isinstance(df_engine, DaskEngine): + df = df_engine.df_lib.from_pandas(df, npartitions=npartitions) + probs = (0.7, 0.1, 0.2) split_params = { "type": "datetime",