Skip to content

Commit

Permalink
mypy
Browse files Browse the repository at this point in the history
  • Loading branch information
yuhan committed Sep 7, 2021
1 parent 1394e44 commit cb85958
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions python_modules/dagster/dagster/core/definitions/sensor.py
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,7 @@ def minimum_interval_seconds(self) -> Optional[int]:
return self._min_interval

@property
def targets(self) -> str:
def targets(self) -> Optional[List[Union[DirectTarget, RepoRelativeTarget]]]:
return self._targets

def has_loadable_targets(self) -> bool:
Expand Down Expand Up @@ -373,7 +373,7 @@ def __init__(
)

@property
def _target(self) -> str:
def _target(self) -> Optional[Union[DirectTarget, RepoRelativeTarget]]:
return self._targets[0] if self._targets else None

@property
Expand Down Expand Up @@ -611,7 +611,7 @@ def __init__(
["SensorEvaluationContext"],
Union[Generator[Union[RunRequest, SkipReason], None, None], RunRequest, SkipReason],
],
jobs: List[Union[GraphDefinition, PipelineDefinition]] = None,
jobs: List[Union[GraphDefinition, PipelineDefinition]],
minimum_interval_seconds: Optional[int] = None,
description: Optional[str] = None,
decorated_fn: Optional[
Expand All @@ -622,7 +622,9 @@ def __init__(
] = None,
):
check.list_param(jobs, "jobs", (GraphDefinition, PipelineDefinition))
targets = [DirectTarget(job) for job in jobs]
targets: Optional[List[Union[DirectTarget, RepoRelativeTarget]]] = [
DirectTarget(job) for job in jobs
]

super(MultiJobSensorDefinition, self).__init__(
name=name,
Expand Down

0 comments on commit cb85958

Please sign in to comment.