@@ -58,7 +58,7 @@ def compile_sql(
58
58
# TODO: get rid of output_ids arg
59
59
assert len (output_ids ) == len (list (node .fields ))
60
60
node = set_output_names (node , output_ids )
61
- node = nodes .top_down (node , rewrites .rewrite_timedelta_ops )
61
+ node = nodes .top_down (node , rewrites .rewrite_timedelta_expressions )
62
62
if ordered :
63
63
node , limit = rewrites .pullup_limit_from_slice (node )
64
64
node = nodes .bottom_up (node , rewrites .rewrite_slice )
@@ -85,7 +85,7 @@ def compile_sql(
85
85
def compile_peek_sql (self , node : nodes .BigFrameNode , n_rows : int ) -> str :
86
86
ids = [id .sql for id in node .ids ]
87
87
node = nodes .bottom_up (node , rewrites .rewrite_slice )
88
- node = nodes .top_down (node , rewrites .rewrite_timedelta_ops )
88
+ node = nodes .top_down (node , rewrites .rewrite_timedelta_expressions )
89
89
node , _ = rewrites .pull_up_order (
90
90
node , order_root = False , ordered_joins = self .strict
91
91
)
@@ -99,7 +99,7 @@ def compile_raw(
99
99
str , typing .Sequence [google .cloud .bigquery .SchemaField ], bf_ordering .RowOrdering
100
100
]:
101
101
node = nodes .bottom_up (node , rewrites .rewrite_slice )
102
- node = nodes .top_down (node , rewrites .rewrite_timedelta_ops )
102
+ node = nodes .top_down (node , rewrites .rewrite_timedelta_expressions )
103
103
node , ordering = rewrites .pull_up_order (node , ordered_joins = self .strict )
104
104
node = rewrites .column_pruning (node )
105
105
ir = self .compile_node (node )
@@ -108,7 +108,7 @@ def compile_raw(
108
108
109
109
def _preprocess (self , node : nodes .BigFrameNode ):
110
110
node = nodes .bottom_up (node , rewrites .rewrite_slice )
111
- node = nodes .top_down (node , rewrites .rewrite_timedelta_ops )
111
+ node = nodes .top_down (node , rewrites .rewrite_timedelta_expressions )
112
112
node , _ = rewrites .pull_up_order (
113
113
node , order_root = False , ordered_joins = self .strict
114
114
)
0 commit comments