Skip to content

Commit

Permalink
Fix linter errors
Browse files Browse the repository at this point in the history
  • Loading branch information
jaredoconnell committed Aug 15, 2024
1 parent 75c504a commit 5103ab5
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions src/arcaflow_plugin_sdk/atp.py
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,9 @@ def run_plugin(
# potentially interfering with the atp pipes.
original_stdout = sys.stdout
original_stderr = sys.stderr
self.user_out_wrapper = io.TextIOWrapper(io.BytesIO(), sys.stdout.encoding)
self.user_out_wrapper = io.TextIOWrapper(
io.BytesIO(), sys.stdout.encoding
)
sys.stdout = self.user_out_wrapper
sys.stderr = self.user_out_wrapper

Expand Down Expand Up @@ -325,7 +327,7 @@ def start_step(self, run_id: str, step_id: str, config: typing.Any):
)

self.user_out_wrapper.flush()
self.user_out_wrapper.seek(0) # go to start so that we can read stdout.
self.user_out_wrapper.seek(0) # go to start to read stdout.
# Send WorkDoneMessage
self.send_runtime_message(
MessageType.WORK_DONE,
Expand Down

0 comments on commit 5103ab5

Please sign in to comment.