Skip to content

Commit

Permalink
Update asset loading test
Browse files Browse the repository at this point in the history
  • Loading branch information
BernardWez committed Nov 21, 2023
1 parent b026e77 commit 29a2f39
Showing 1 changed file with 5 additions and 11 deletions.
16 changes: 5 additions & 11 deletions tests/test_elx/test_extensions/test_dagster/test_assets.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,18 +7,12 @@ def test_asset_loading(runner: Runner):
"""
Test that assets are loaded correctly.
"""
assets = load_assets(runner)
assert len(assets) == 1
assert isinstance(assets[0], AssetsDefinition)

# Verifies that the tap associated with the runner has 2 streams
assert len(runner.tap.catalog.streams) == 2

def test_asset_loading_with_deselected_stream(runner_with_deselected_stream: Runner):
"""
Test that assets are loaded correctly.
"""
# Verifies that the associated tap has multiple streams
assert len(runner_with_deselected_stream.tap.catalog.streams) == 2
# Load assets
assets = load_assets(runner)

assets = load_assets(runner_with_deselected_stream)
# Length of assets should be 1 as one stream is deselected per default
assert len(assets) == 1
assert isinstance(assets[0], AssetsDefinition)

0 comments on commit 29a2f39

Please sign in to comment.