Differential D804 Diff 3678 python_modules/dagster-graphql/dagster_graphql/implementation/scheduler/scheduler.py

Changeset View

Standalone View

	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 Line(s)

	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'),
	)			)