fix black formatting (#10298)

dagster-io · Nov 1, 2022 · 1dd602a · 1dd602a
1 parent 2b3280f
commit 1dd602a
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_execute_pipeline.py b/python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_execute_pipeline.py
@@ -413,7 +413,10 @@ def test_basic_start_pipeline_execution_and_subscribe(self, graphql_context):
             if message["__typename"] not in ("EngineEvent", "RunEnqueuedEvent", "RunDequeuedEvent")
         ]
 
-        assert non_engine_event_types == self._csv_hello_world_event_sequence() or non_engine_event_types == self._legacy_csv_hello_world_event_sequence()
+        assert (
+            non_engine_event_types == self._csv_hello_world_event_sequence()
+            or non_engine_event_types == self._legacy_csv_hello_world_event_sequence()
+        )
 
     def test_basic_start_pipeline_and_fetch(self, graphql_context):
         selector = infer_pipeline_selector(graphql_context, "csv_hello_world")
@@ -457,7 +460,10 @@ def test_basic_start_pipeline_and_fetch(self, graphql_context):
             for message in events_result.data["logsForRun"]["events"]
             if message["__typename"] not in ("EngineEvent", "RunEnqueuedEvent", "RunDequeuedEvent")
         ]
-        assert non_engine_event_types == self._csv_hello_world_event_sequence() or non_engine_event_types == self._legacy_csv_hello_world_event_sequence()
+        assert (
+            non_engine_event_types == self._csv_hello_world_event_sequence()
+            or non_engine_event_types == self._legacy_csv_hello_world_event_sequence()
+        )
 
     def test_basic_start_pipeline_and_poll(self, graphql_context):
         selector = infer_pipeline_selector(graphql_context, "csv_hello_world")
@@ -522,7 +528,10 @@ def _fetch_events(cursor):
             for message in full_logs
             if message["__typename"] not in ("EngineEvent", "RunEnqueuedEvent", "RunDequeuedEvent")
         ]
-        assert non_engine_event_types == self._csv_hello_world_event_sequence() or non_engine_event_types == self._legacy_csv_hello_world_event_sequence()
+        assert (
+            non_engine_event_types == self._csv_hello_world_event_sequence()
+            or non_engine_event_types == self._legacy_csv_hello_world_event_sequence()
+        )
 
     def test_step_failure(self, graphql_context):
         selector = infer_pipeline_selector(graphql_context, "naughty_programmer_pipeline")