55
66import daft .functions as F
77from daft import Window , col , lit
8- from narwhals ._compliant import CompliantExpr
98from narwhals ._expression_parsing import (
109 combine_alias_output_names ,
1110 combine_evaluate_output_names ,
1211)
1312from narwhals ._utils import Implementation , not_implemented
13+ from narwhals .compliant import CompliantExpr
1414
1515from narwhals_daft .expr_dt import ExprDateTimeNamesSpace
1616from narwhals_daft .expr_name import ExprNameNamespace
2121 from collections .abc import Callable , Sequence
2222
2323 from daft import Expression
24- from narwhals ._compliant .typing import AliasNames , EvalNames , EvalSeries
2524 from narwhals ._utils import Version , _LimitedContext
2625 from narwhals .dtypes import DType
2726 from narwhals .typing import RankMethod
3332 WindowFunction : TypeAlias = Callable [
3433 [DaftLazyFrame , "WindowInputs" ], Sequence [Expression ]
3534 ]
35+ AliasNames : TypeAlias = Callable [[Sequence [str ]], Sequence [str ]]
36+ EvalNames : TypeAlias = Callable [[DaftLazyFrame ], Sequence [str ]]
3637
3738
3839class WindowInputs :
@@ -53,7 +54,7 @@ def __init__(
5354 call : Callable [[DaftLazyFrame ], Sequence [Expression ]],
5455 window_function : WindowFunction | None = None ,
5556 * ,
56- evaluate_output_names : EvalNames [ DaftLazyFrame ] ,
57+ evaluate_output_names : EvalNames ,
5758 alias_output_names : AliasNames | None ,
5859 version : Version ,
5960 ) -> None :
@@ -226,7 +227,7 @@ def fn(names: Sequence[str]) -> Sequence[str]:
226227 @classmethod
227228 def from_column_names (
228229 cls : type [DaftExpr ],
229- evaluate_column_names : EvalNames [ DaftLazyFrame ] ,
230+ evaluate_column_names : EvalNames ,
230231 / ,
231232 * ,
232233 context : _LimitedContext ,
@@ -280,7 +281,7 @@ def window_function(
280281
281282 def _callable_to_eval_series (
282283 self , call : Callable [..., Expression ], / , ** expressifiable_args : DaftExpr
283- ) -> EvalSeries [ DaftLazyFrame , Expression ]:
284+ ) -> Callable [[ DaftLazyFrame ], Sequence [ Expression ] ]:
284285 def func (df : DaftLazyFrame ) -> list [Expression ]:
285286 native_series_list = self (df )
286287 other_native_series = {
0 commit comments