diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/actual_dag.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/actual_dag.py index 71fe11c5152e..c982fc0112db 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/actual_dag.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/actual_dag.py @@ -11,33 +11,33 @@ def solid_a(): return 1 -@lambda_solid(inputs=[InputDefinition("arg_a")]) +@lambda_solid(inputs=[InputDefinition('arg_a')]) def solid_b(arg_a): return arg_a * 2 -@lambda_solid(inputs=[InputDefinition("arg_a")]) +@lambda_solid(inputs=[InputDefinition('arg_a')]) def solid_c(arg_a): return arg_a * 3 -@lambda_solid(inputs=[InputDefinition("arg_b"), InputDefinition("arg_c")]) +@lambda_solid(inputs=[InputDefinition('arg_b'), InputDefinition('arg_c')]) def solid_d(arg_b, arg_c): return arg_b * arg_c def define_diamond_dag_pipeline(): return PipelineDefinition( - name="actual_dag_pipeline", + name='actual_dag_pipeline', # The order of this list does not matter: # dependencies determine execution order solids=[solid_d, solid_c, solid_b, solid_a], dependencies={ - "solid_b": {"arg_a": DependencyDefinition("solid_a")}, - "solid_c": {"arg_a": DependencyDefinition("solid_a")}, - "solid_d": { - "arg_b": DependencyDefinition("solid_b"), - "arg_c": DependencyDefinition("solid_c"), + 'solid_b': {'arg_a': DependencyDefinition('solid_a')}, + 'solid_c': {'arg_a': DependencyDefinition('solid_a')}, + 'solid_d': { + 'arg_b': DependencyDefinition('solid_b'), + 'arg_c': DependencyDefinition('solid_c'), }, }, ) diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/config.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/config.py index 4a1391f2bbf7..bdf895f2cc78 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/config.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/config.py @@ -4,25 +4,25 @@ @solid( - config_field=Field(types.String, is_optional=True, default_value="en-us") + config_field=Field(types.String, is_optional=True, default_value='en-us') ) def configurable_hello(info): - if len(info.config) >= 3 and info.config[:3] == "haw": - return "Aloha honua!" - elif len(info.config) >= 2 and info.config[:2] == "cn": - return "你好, 世界!" + if len(info.config) >= 3 and info.config[:3] == 'haw': + return 'Aloha honua!' + elif len(info.config) >= 2 and info.config[:2] == 'cn': + return '你好, 世界!' else: - return "Hello, world!" + return 'Hello, world!' def define_configurable_hello_pipeline(): return PipelineDefinition( - name="configurable_hello_pipeline", solids=[configurable_hello] + name='configurable_hello_pipeline', solids=[configurable_hello] ) def test_intro_tutorial_part_four(): execute_pipeline( define_configurable_hello_pipeline(), - {"solids": {"configurable_hello": {"config": "cn"}}}, + {'solids': {'configurable_hello': {'config': 'cn'}}}, ) diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/repos.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/repos.py index ed4c4c417c99..6ecd29ed7134 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/repos.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/repos.py @@ -7,11 +7,11 @@ def hello_world(): def define_repo_demo_pipeline(): - return PipelineDefinition(name="repo_demo_pipeline", solids=[hello_world]) + return PipelineDefinition(name='repo_demo_pipeline', solids=[hello_world]) def define_repo(): return RepositoryDefinition( - name="demo_repository", - pipeline_dict={"repo_demo_pipeline": define_repo_demo_pipeline}, + name='demo_repository', + pipeline_dict={'repo_demo_pipeline': define_repo_demo_pipeline}, ) diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_actual_dag.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_actual_dag.py index 881653b9d90b..d90c9755ad0a 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_actual_dag.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_actual_dag.py @@ -12,14 +12,14 @@ def test_intro_tutorial_actual_dag(): assert result.success assert len(result.result_list) == 4 - assert result.result_for_solid("solid_a").transformed_value() == 1 - assert result.result_for_solid("solid_b").transformed_value() == 2 - assert result.result_for_solid("solid_c").transformed_value() == 3 - assert result.result_for_solid("solid_d").transformed_value() == 6 + assert result.result_for_solid('solid_a').transformed_value() == 1 + assert result.result_for_solid('solid_b').transformed_value() == 2 + assert result.result_for_solid('solid_c').transformed_value() == 3 + assert result.result_for_solid('solid_d').transformed_value() == 6 return result def test_intro_tutorial_cli_actual_dag(): check_cli_execute_file_pipeline( - script_relative_path("../actual_dag.py"), "define_diamond_dag_pipeline" + script_relative_path('../actual_dag.py'), 'define_diamond_dag_pipeline' ) diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_config.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_config.py index 2f53a1984cf6..a61a18cfe6ce 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_config.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_config.py @@ -14,25 +14,25 @@ def test_tutorial_part_four(): pipeline = define_configurable_hello_pipeline() result = execute_pipeline( - pipeline, {"solids": {"configurable_hello": {"config": "cn"}}} + pipeline, {'solids': {'configurable_hello': {'config': 'cn'}}} ) assert result.success assert len(result.result_list) == 1 assert ( - result.result_for_solid("configurable_hello").transformed_value() - == "你好, 世界!" + result.result_for_solid('configurable_hello').transformed_value() + == '你好, 世界!' ) return result def test_tutorial_script_part_four(): - check_script(script_relative_path("../config.py")) + check_script(script_relative_path('../config.py')) def test_tutorial_cli_part_four(): check_cli_execute_file_pipeline( - script_relative_path("../config.py"), - "define_configurable_hello_pipeline", - script_relative_path("../config_env.yml"), + script_relative_path('../config.py'), + 'define_configurable_hello_pipeline', + script_relative_path('../config_env.yml'), ) diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_hello_dag.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_hello_dag.py index 20a7c5ba4e72..36f7c0756fe4 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_hello_dag.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_hello_dag.py @@ -12,12 +12,12 @@ def test_intro_tutorial_hello_dag(): assert result.success assert len(result.result_list) == 2 - assert result.result_for_solid("solid_one").transformed_value() == "foo" - assert result.result_for_solid("solid_two").transformed_value() == "foofoo" + assert result.result_for_solid('solid_one').transformed_value() == 'foo' + assert result.result_for_solid('solid_two').transformed_value() == 'foofoo' return result def test_tutorial_cli_hello_dag(): check_cli_execute_file_pipeline( - script_relative_path("../hello_dag.py"), "define_hello_dag_pipeline" + script_relative_path('../hello_dag.py'), 'define_hello_dag_pipeline' ) diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_inputs.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_inputs.py index 47019f2bce0e..9b8c2a29d1fe 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_inputs.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_inputs.py @@ -13,15 +13,15 @@ def test_hello_inputs_parameterized_pipeline(): result = execute_with_another_world() assert result.success - solid_result = result.result_for_solid("add_hello_to_word") - assert solid_result.transformed_value() == "Hello, Mars!" + solid_result = result.result_for_solid('add_hello_to_word') + assert solid_result.transformed_value() == 'Hello, Mars!' def test_hello_inputs_parameterized_cli_pipeline(): check_cli_execute_file_pipeline( - script_relative_path("../inputs.py"), - "define_hello_inputs_pipeline", - script_relative_path("../inputs_env.yml"), + script_relative_path('../inputs.py'), + 'define_hello_inputs_pipeline', + script_relative_path('../inputs_env.yml'), ) @@ -29,5 +29,5 @@ def test_hello_typed_inputs(): with pytest.raises(PipelineConfigEvaluationError): execute_pipeline( define_hello_typed_inputs_pipeline(), - {"solids": {"add_hello_to_word": {"inputs": {"word": 343}}}}, + {'solids': {'add_hello_to_word': {'inputs': {'word': 343}}}}, ) diff --git a/python_modules/dagster/dagster/tutorials/intro_tutorial/tutorial_repository.py b/python_modules/dagster/dagster/tutorials/intro_tutorial/tutorial_repository.py index 9c3bca6c4b9d..5cb1d3d6493a 100644 --- a/python_modules/dagster/dagster/tutorials/intro_tutorial/tutorial_repository.py +++ b/python_modules/dagster/dagster/tutorials/intro_tutorial/tutorial_repository.py @@ -9,12 +9,12 @@ def define_repository(): return RepositoryDefinition( - name="tutorial_repository", + name='tutorial_repository', pipeline_dict={ - "hello_world_pipeline": define_hello_world_pipeline, - "hello_dag_pipeline": define_hello_dag_pipeline, - "actual_dag_pipeline": define_diamond_dag_pipeline, - "configurable_hello_pipeline": define_configurable_hello_pipeline, - "execution_context_pipeline": define_execution_context_pipeline_step_two, + 'hello_world_pipeline': define_hello_world_pipeline, + 'hello_dag_pipeline': define_hello_dag_pipeline, + 'actual_dag_pipeline': define_diamond_dag_pipeline, + 'configurable_hello_pipeline': define_configurable_hello_pipeline, + 'execution_context_pipeline': define_execution_context_pipeline_step_two, }, )