formatting

Author: jrmccluskey

sdks/python/apache_beam/runners/dataflow/dataflow_runner.py

@@ -759,8 +759,8 @@ def api_jobstate_to_pipeline_state(api_jobstate):
             values_enum.JOB_STATE_CANCELLING: PipelineState.CANCELLING,
             values_enum.JOB_STATE_RESOURCE_CLEANING_UP: PipelineState.
             RESOURCE_CLEANING_UP,
-            values_enum.JOB_STATE_PAUSING : PipelineState.PAUSING,
-            values_enum.JOB_STATE_PAUSED : PipelineState.PAUSED,
+            values_enum.JOB_STATE_PAUSING: PipelineState.PAUSING,
+            values_enum.JOB_STATE_PAUSED: PipelineState.PAUSED,
         })
 
     return (

sdks/python/apache_beam/runners/dataflow/internal/apiclient_test.py

@@ -492,7 +492,6 @@ def test_translate_distribution_using_distribution_data(self):
     self.assertEqual(
         metric_update.distribution['count'], distribution_update.count)
 
-
   def test_translate_distribution_using_dataflow_distribution_counter(self):
     counter_update = DataflowDistributionCounter()
     counter_update.add_input(1)
@@ -504,14 +503,12 @@ def test_translate_distribution_using_dataflow_distribution_counter(self):
     self.assertEqual(metric_proto.distribution['min'], counter_update.min)
     self.assertEqual(metric_proto.distribution['max'], counter_update.max)
     self.assertEqual(metric_proto.distribution['sum'], counter_update.sum)
-    self.assertEqual(
-        metric_proto.distribution['count'], counter_update.count)
+    self.assertEqual(metric_proto.distribution['count'], counter_update.count)
     self.assertEqual(
         metric_proto.distribution['firstBucketOffset'],
         histogram.firstBucketOffset)
     self.assertEqual(
-        metric_proto.distribution['bucketCounts'],
-        histogram.bucketCounts)
+        metric_proto.distribution['bucketCounts'], histogram.bucketCounts)
 
   def test_translate_means(self):
     metric_update = dataflow.MetricUpdate()
@@ -1789,5 +1786,6 @@ def seekable(self):
           mock_sleep.assert_not_called()
           mock_file_open.assert_not_called()
 
+
 if __name__ == '__main__':
   unittest.main()