Skip to content

Commit

Permalink
fix errors (#7577)
Browse files Browse the repository at this point in the history
  • Loading branch information
smackesey committed Apr 26, 2022
1 parent 6e12f83 commit b87ef89
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -339,9 +339,9 @@ def qux(baz):

def test_fail_with_get_output_asset_key():
@io_manager
def my_io_manager(context):
def my_io_manager(_context):
class Mine(IOManager):
def get_output_asset_key(self, context):
def get_output_asset_key(self, _context):
return AssetKey("hey")

def handle_output(self, context, obj):
Expand All @@ -363,8 +363,8 @@ def bar(foo):
job = build_assets_job("x", [foo, bar], resource_defs={"io_manager": my_io_manager})
with pytest.raises(
DagsterInvariantViolationError,
match='The IOManager of output "result" on node "foo" associates it with asset key '
"\"AssetKey\(\['hey'\]\)\", but this output has already been defined to produce asset "
"\"AssetKey\(\['foo'\]\)\"",
match=r'The IOManager of output "result" on node "foo" associates it with asset key '
r"\"AssetKey\(\['hey'\]\)\", but this output has already been defined to produce asset "
r"\"AssetKey\(\['foo'\]\)\"",
):
job.execute_in_process()
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
import pytest

from dagster import AssetKey, DagsterInvariantViolationError, Out
from dagster.check import CheckError
from dagster.core.asset_defs import AssetIn, SourceAsset, asset, build_assets_job, multi_asset
from dagster.core.definitions.metadata import MetadataEntry, MetadataValue
from dagster.core.host_representation.external_data import (
Expand Down

0 comments on commit b87ef89

Please sign in to comment.