Skip to content

Commit

Permalink
chore: cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
JasperHG90 committed May 25, 2024
1 parent 27272b1 commit 4969d2a
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions cloud_function/fn_pipes.py
Original file line number Diff line number Diff line change
Expand Up @@ -75,8 +75,7 @@ def __init__(
def upload_messages_chunk(self, payload: IO, index: int) -> None:
key = f"{self._key_prefix}/{index}.json" if self._key_prefix else f"{index}.json"
blob = self._bucket.blob(key)
body = payload.read()
blob.upload_from_string(body)
blob.upload_from_string(payload.read())


class PipesCloudLoggerMessageWriterChannel(PipesMessageWriterChannel):
Expand Down

0 comments on commit 4969d2a

Please sign in to comment.