Page MenuHomePhabricator
Differential D5228 Diff 26378 python_modules/dagster/dagster_tests/cli_tests/command_tests/test_cli_commands.py

Changeset View

Standalone View

View Options

python_modules/dagster/dagster_tests/cli_tests/command_tests/test_cli_commands.py

Show All 17 Linesfrom dagster import (
repository, repository,
seven, seven,
solid, solid,
) )
from dagster.cli import ENV_PREFIX, cli from dagster.cli import ENV_PREFIX, cli
from dagster.cli.pipeline import pipeline_execute_command from dagster.cli.pipeline import pipeline_execute_command
from dagster.cli.run import run_list_command, run_wipe_command from dagster.cli.run import run_list_command, run_wipe_command
from dagster.core.definitions.decorators.sensor import sensor from dagster.core.definitions.decorators.sensor import sensor
from dagster.core.definitions.sensor import SensorRunParams from dagster.core.definitions.sensor import RunRequest
from dagster.core.test_utils import instance_for_test, instance_for_test_tempdir from dagster.core.test_utils import instance_for_test, instance_for_test_tempdir
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 file_relative_path, merge_dicts from dagster.utils import file_relative_path, merge_dicts
from dagster.version import __version__ from dagster.version import __version__
def no_print(_): def no_print(_):
▲ Show 20 Lines • Show All 80 Lines • ▼ Show 20 Lines
def define_bar_sensors(): def define_bar_sensors():
@sensor(pipeline_name="baz") @sensor(pipeline_name="baz")
def foo_sensor(context): def foo_sensor(context):
run_config = {"foo": "FOO"} run_config = {"foo": "FOO"}
if context.last_completion_time: if context.last_completion_time:
run_config["since"] = context.last_completion_time run_config["since"] = context.last_completion_time
return SensorRunParams(execution_key=None, run_config=run_config) return RunRequest(run_key=None, run_config=run_config)
return {"foo_sensor": foo_sensor} return {"foo_sensor": foo_sensor}
@repository @repository
def bar(): def bar():
return { return {
"pipelines": { "pipelines": {
▲ Show 20 Lines • Show All 481 Lines • Show Last 20 Lines