From d66fe8d4ba33bcb2da1a35faa2458b5dd46847b6 Mon Sep 17 00:00:00 2001 From: Dmitry Chigarev Date: Thu, 12 Oct 2023 13:39:07 +0000 Subject: [PATCH] add more logs Signed-off-by: Dmitry Chigarev --- .../pandas_on_ray/partitioning/partition_manager.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/modin/core/execution/ray/implementations/pandas_on_ray/partitioning/partition_manager.py b/modin/core/execution/ray/implementations/pandas_on_ray/partitioning/partition_manager.py index 50924543db2..72136e08c65 100644 --- a/modin/core/execution/ray/implementations/pandas_on_ray/partitioning/partition_manager.py +++ b/modin/core/execution/ray/implementations/pandas_on_ray/partitioning/partition_manager.py @@ -107,6 +107,10 @@ def split_pandas_df_into_partitions( log = get_logger() if not distributed_splitting: + print( + "Using sequential splitting in '.from_pandas()' because of some of the condition is False: " + + f"{enough_elements=}; {all_numeric_types=}; {three_copies_fits_into_memory=}" + ) log.info( "Using sequential splitting in '.from_pandas()' because of some of the condition is False: " + f"{enough_elements=}; {all_numeric_types=}; {three_copies_fits_into_memory=}" @@ -115,6 +119,7 @@ def split_pandas_df_into_partitions( df, row_chunksize, col_chunksize, update_bar ) + print("Using distributed splitting in '.from_pandas()'") log.info("Using distributed splitting in '.from_pandas()'") put_func = cls._partition_class.put