Skip to content

Commit

Permalink
fix line too long style error
Browse files Browse the repository at this point in the history
  • Loading branch information
megatron-me-uk committed Jun 4, 2015
1 parent 5745d85 commit 45f4977
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion python/pyspark/rdd.py
Original file line number Diff line number Diff line change
Expand Up @@ -707,7 +707,8 @@ def pipe_objs(out):
result = (x.rstrip(b'\n').decode('utf-8') for x in iter(pipe.stdout.readline, b''))
pipe.wait()
if pipe.returncode:
raise Exception("Pipe function `%s' exited with error code %d" %(command, pipe.returncode))
raise Exception("Pipe function `%s' exited"
"with error code %d" %(command, pipe.returncode))
return result
return self.mapPartitions(func)

Expand Down

0 comments on commit 45f4977

Please sign in to comment.