Skip to content

Commit

Permalink
updated lint error
Browse files Browse the repository at this point in the history
Signed-off-by: Ketan Umare <[email protected]>
  • Loading branch information
kumare3 committed Jan 18, 2023
1 parent c1abc4b commit e283640
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 12 deletions.
3 changes: 2 additions & 1 deletion flytekit/core/promise.py
Original file line number Diff line number Diff line change
Expand Up @@ -854,7 +854,8 @@ def create_and_link_node_from_remote(
extra_inputs = used_inputs ^ set(kwargs.keys())
if len(extra_inputs) > 0:
raise _user_exceptions.FlyteAssertion(
"Too many inputs were specified for the interface. Extra inputs were: {}".format(extra_inputs)
f"Too many inputs for [{entity.name}] Expected inputs: {typed_interface.inputs.keys()} "
f"- extra inputs: {extra_inputs}"
)

# Detect upstream nodes
Expand Down
13 changes: 2 additions & 11 deletions flytekit/remote/lazy_entity.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,17 +41,8 @@ def entity(self) -> T:
self._entity = self._getter()
except AttributeError as e:
raise RuntimeError(
f"Error downloading the entity {self._name}, (check original exception...)") from e
return self._entity

@property
def entity(self) -> T:
"""
If not already fetched / available, then the entity will be force fetched.
"""
with self._mutex:
if self._entity is None:
self._entity = self._getter()
f"Error downloading the entity {self._name}, (check original exception...)"
) from e
return self._entity

def __getattr__(self, item: str) -> typing.Any:
Expand Down

0 comments on commit e283640

Please sign in to comment.