From cb85958a06770b3afd1d7d435f7d1185aa59655b Mon Sep 17 00:00:00 2001 From: yuhan Date: Tue, 7 Sep 2021 01:47:55 -0700 Subject: [PATCH] mypy --- .../dagster/dagster/core/definitions/sensor.py | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/python_modules/dagster/dagster/core/definitions/sensor.py b/python_modules/dagster/dagster/core/definitions/sensor.py index 3fd251a3ec34b..ce185baa2b4e6 100644 --- a/python_modules/dagster/dagster/core/definitions/sensor.py +++ b/python_modules/dagster/dagster/core/definitions/sensor.py @@ -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: @@ -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 @@ -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[ @@ -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,