File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change 9
9
from ray ._private .internal_api import get_memory_info_reply , get_state_from_address
10
10
from ray .data ._internal .execution .interfaces import RefBundle
11
11
from ray .data ._internal .logical .interfaces import SourceOperator
12
- from ray .data ._internal .logical .interfaces .operator import Operator
12
+ from ray .data ._internal .logical .interfaces .logical_operator import LogicalOperator
13
13
from ray .data ._internal .logical .interfaces .logical_plan import LogicalPlan
14
+ from ray .data ._internal .logical .interfaces .operator import Operator
14
15
from ray .data ._internal .logical .operators .read_operator import Read
15
16
from ray .data ._internal .stats import DatasetStats
16
17
from ray .data ._internal .util import unify_ref_bundles_schema
@@ -134,7 +135,7 @@ def generate_plan_string(
134
135
):
135
136
"""Traverse (DFS) the Plan DAG and
136
137
return a string representation of the operators."""
137
- if ( including_source == False ) and isinstance (op , SourceOperator ):
138
+ if not including_source and isinstance (op , SourceOperator ):
138
139
return curr_str , depth
139
140
140
141
curr_max_depth = depth
Original file line number Diff line number Diff line change @@ -5965,6 +5965,7 @@ def stats(self) -> str:
5965
5965
return self ._write_ds .stats ()
5966
5966
return self ._get_stats_summary ().to_string ()
5967
5967
5968
+ @PublicAPI (api_group = IM_API_GROUP )
5968
5969
def explain (self ) -> str :
5969
5970
"""Returns a string containing logical plan and physical plan.
5970
5971
You can’t perform that action at this time.
0 commit comments