Skip to content

Commit

Permalink
fix lint/mypy failures (#7183)
Browse files Browse the repository at this point in the history
* fix lint check

* fix mypy
  • Loading branch information
prha committed Mar 24, 2022
1 parent 1fff21f commit c1d674d
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -186,6 +186,11 @@ def execute_in_process(
"Cannot provide both run_config and partition_key arguments to `execute_in_process`",
)
partition_set = self.get_partition_set_def()
if not partition_set:
check.failed(
f"Provided partition key `{partition_key}` for job `{self._name}` without a partitioned config"
)

partition = partition_set.get_partition(partition_key)
run_config = partition_set.run_config_for_partition(partition)
tags = partition_set.tags_for_partition(partition)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@
from dateutil.relativedelta import relativedelta

from dagster import check
from dagster.core.storage.tags import PARTITION_NAME_TAG
from dagster.serdes import whitelist_for_serdes

from ...seven.compat.pendulum import PendulumDateTime, to_timezone
Expand Down

0 comments on commit c1d674d

Please sign in to comment.