Differential D4787 Diff 23763 python_modules/dagster/dagster_tests/api_tests/test_launch_scheduled_execution.py

Changeset View

Standalone View

	Show All 12 Lines
	from dagster.core.origin import RepositoryGrpcServerOrigin			from dagster.core.origin import RepositoryGrpcServerOrigin
	from dagster.core.scheduler import (			from dagster.core.scheduler import (
	ScheduleTickStatus,			ScheduleTickStatus,
	ScheduledExecutionFailed,			ScheduledExecutionFailed,
	ScheduledExecutionSkipped,			ScheduledExecutionSkipped,
	ScheduledExecutionSuccess,			ScheduledExecutionSuccess,
	)			)
	from dagster.core.telemetry import get_dir_from_dagster_home			from dagster.core.telemetry import get_dir_from_dagster_home
	from dagster.core.test_utils import instance_for_test			from dagster.core.test_utils import instance_for_test, today_at_midnight
	from dagster.core.types.loadable_target_origin import LoadableTargetOrigin			from dagster.core.types.loadable_target_origin import LoadableTargetOrigin
	from dagster.grpc.server import GrpcServerProcess			from dagster.grpc.server import GrpcServerProcess
	from dagster.utils import find_free_port			from dagster.utils import find_free_port

	_COUPLE_DAYS_AGO = datetime.datetime.now() - datetime.timedelta(days=2)			_COUPLE_DAYS_AGO = today_at_midnight() - datetime.timedelta(days=2)


	def _throw(_context):			def _throw(_context):
	raise Exception("bananas")			raise Exception("bananas")


	def _never(_context):			def _never(_context):
	return False			return False
	▲ Show 20 Lines • Show All 257 Lines • Show Last 20 Lines