Fixes line-to-long lint error.

mransley · Nov 8, 2019 · be08efd · be08efd
1 parent f6ce376
commit be08efd
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -1223,7 +1223,8 @@ def run_TestStream(self, transform_node, options):
  element.encoded_element = output_coder.encode(tv.value)
  element.timestamp = tv.timestamp.micros
  elif isinstance(event, ProcessingTimeEvent):
- new_event.processing_time_event.advance_duration = event.advance_by.micros
+ new_event.processing_time_event.advance_duration = (
+ event.advance_by.micros)
  elif isinstance(event, WatermarkEvent):
  new_event.watermark_event.new_watermark = event.new_watermark.micros
  serialized_payload = self.byte_array_to_json_string(