Skip to content

Commit

Permalink
nits
Browse files Browse the repository at this point in the history
Signed-off-by: Yee Hing Tong <[email protected]>
  • Loading branch information
wild-endeavor committed Nov 28, 2022
1 parent f0df00b commit 5c37326
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
4 changes: 2 additions & 2 deletions flytekit/core/data_persistence.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@

from flytekit.configuration import DataConfig
from flytekit.core.utils import PerformanceTimer
from flytekit.exceptions.user import FlyteAssertion
from flytekit.exceptions.user import FlyteAssertion, FlyteValueException
from flytekit.interfaces.random import random
from flytekit.loggers import logger

Expand Down Expand Up @@ -232,7 +232,7 @@ def copy_tree(self, from_path: str, to_path: str):
tp = pathlib.Path(self.strip_file_header(to_path))
if tp.exists():
if not tp.is_dir():
raise ValueError("not a dir")
raise FlyteValueException(tp, f"Target {tp} exists but is not a dir")
files = os.listdir(tp)
if len(files) != 0:
logger.debug(f"Deleting existing target dir {tp} with files {files}")
Expand Down
1 change: 0 additions & 1 deletion tests/flytekit/unit/core/test_workflows.py
Original file line number Diff line number Diff line change
Expand Up @@ -316,7 +316,6 @@ def schema_to_sd_wf() -> (pd.DataFrame, pd.DataFrame):


def test_structured_dataset_wf():
# res = sd_to_schema_wf()
assert_frame_equal(sd_wf(), subset_df)
assert_frame_equal(sd_to_schema_wf(), superset_df)
assert_frame_equal(schema_to_sd_wf()[0], subset_df)
Expand Down

0 comments on commit 5c37326

Please sign in to comment.