Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
schrockn committed Sep 19, 2023
1 parent 440893e commit 808fc37
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from typing import AbstractSet
from typing import AbstractSet, Iterable

import pytest
from dagster import (
Expand Down Expand Up @@ -128,12 +128,12 @@ def an_asset(source_asset: str) -> str:


def get_job_for_assets(defs: Definitions, *coercibles_or_defs) -> JobDefinition:
job_def = defs.get_implicit_job_def_for_assets(set_from_coercibles_or_defs(*coercibles_or_defs))
job_def = defs.get_implicit_job_def_for_assets(set_from_coercibles_or_defs(coercibles_or_defs))
assert job_def, "Expected to find a job def"
return job_def


def set_from_coercibles_or_defs(*coercibles_or_defs) -> AbstractSet["AssetKey"]:
def set_from_coercibles_or_defs(coercibles_or_defs: Iterable) -> AbstractSet["AssetKey"]:
return set(
[
AssetKey.from_coercible_or_definition(coercible_or_def)
Expand Down

0 comments on commit 808fc37

Please sign in to comment.