Skip to content

Commit

Permalink
Remove unused function
Browse files Browse the repository at this point in the history
  • Loading branch information
uranusjr committed Aug 29, 2022
1 parent 1c929a3 commit f483166
Showing 1 changed file with 0 additions and 12 deletions.
12 changes: 0 additions & 12 deletions airflow/models/expandinput.py
Original file line number Diff line number Diff line change
Expand Up @@ -74,10 +74,6 @@ class DictOfListsExpandInput(NamedTuple):

value: dict[str, OperatorExpandArgument]

def get_unresolved_kwargs(self) -> dict[str, Any]:
"""Get the kwargs dict that can be inferred without resolving."""
return self.value

def iter_parse_time_resolved_kwargs(self) -> Iterable[tuple[str, Sized]]:
"""Generate kwargs with values available on parse-time."""
from airflow.models.xcom_arg import XComArg
Expand Down Expand Up @@ -172,14 +168,6 @@ class ListOfDictsExpandInput(NamedTuple):

value: XComArg

def get_unresolved_kwargs(self) -> dict[str, Any]:
"""Get the kwargs dict that can be inferred without resolving.
Since the list-of-dicts case relies entirely on run-time XCom, there's
no kwargs structure available, so this just returns an empty dict.
"""
return {}

def iter_parse_time_resolved_kwargs(self) -> Iterable[tuple[str, Sized]]:
return ()

Expand Down

0 comments on commit f483166

Please sign in to comment.