Skip to content

Commit

Permalink
Fix filesystem test
Browse files Browse the repository at this point in the history
  • Loading branch information
steinitzu committed May 29, 2024
1 parent 87cfd16 commit 6eb160a
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions tests/load/pipeline/test_filesystem_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -362,8 +362,9 @@ def _collect_table_counts(p) -> Dict[str, int]:
)

# generate 4 loads from 2 pipelines, store load ids
p1 = destination_config.setup_pipeline("p1", dataset_name="layout_test")
p2 = destination_config.setup_pipeline("p2", dataset_name="layout_test")
dataset_name = "layout_test_" + uniq_id()
p1 = destination_config.setup_pipeline("p1", dataset_name=dataset_name)
p2 = destination_config.setup_pipeline("p2", dataset_name=dataset_name)
c1 = cast(FilesystemClient, p1.destination_client())
c2 = cast(FilesystemClient, p2.destination_client())

Expand Down

0 comments on commit 6eb160a

Please sign in to comment.