Single quotes

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

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

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

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

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

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

python_modules/dagster/dagster/tutorials/intro_tutorial/test/test_inputs.py

@@ -13,21 +13,21 @@
 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'),
     )
 
 
 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}}}},
         )

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