Differential D804 Diff 3678 python_modules/dagster-graphql/dagster_graphql/implementation/scheduler/scheduler.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql/implementation/scheduler/scheduler.py
import six | import six | ||||
import abc | import abc | ||||
from collections import namedtuple | from collections import namedtuple | ||||
from dagster import check | from dagster import check | ||||
from dagster_graphql.implementation.execution import ExecutionParams | |||||
class Scheduler(six.with_metaclass(abc.ABCMeta)): | class Scheduler(six.with_metaclass(abc.ABCMeta)): | ||||
@abc.abstractmethod | @abc.abstractmethod | ||||
def create_schedule(self, *args, **kwargs): | def create_schedule(self, *args, **kwargs): | ||||
'''Create a new pipeline schedule. | '''Create a new pipeline schedule. | ||||
Passes args and kwargs to the new Schedule. | Passes args and kwargs to the new Schedule. | ||||
▲ Show 20 Lines • Show All 59 Lines • ▼ Show 20 Lines | |||||
class RunSchedule(namedtuple('RunSchedule', 'schedule_id name cron_schedule execution_params')): | class RunSchedule(namedtuple('RunSchedule', 'schedule_id name cron_schedule execution_params')): | ||||
def __new__(cls, schedule_id, name, cron_schedule, execution_params): | def __new__(cls, schedule_id, name, cron_schedule, execution_params): | ||||
return super(RunSchedule, cls).__new__( | return super(RunSchedule, cls).__new__( | ||||
cls, | cls, | ||||
check.str_param(schedule_id, 'schedule_id'), | check.str_param(schedule_id, 'schedule_id'), | ||||
check.str_param(name, 'name'), | check.str_param(name, 'name'), | ||||
check.str_param(cron_schedule, 'cron_schedule'), | check.str_param(cron_schedule, 'cron_schedule'), | ||||
check.inst_param(execution_params, 'execution_params', ExecutionParams), | check.dict_param(execution_params, 'execution_params'), | ||||
) | ) |