Skip to content

Commit

Permalink
Merge in master and make some minor changes
Browse files Browse the repository at this point in the history
  • Loading branch information
AndrewJGaut committed Sep 10, 2023
1 parent 3d25b77 commit bbe9402
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 6 deletions.
3 changes: 2 additions & 1 deletion codalab/bin/ws_server.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
# Main entry point for CodaLab cl-ws-server.
# Main entry point to the CodaLab Websocket Server.
# The Websocket Server handles communication between the REST server and workers.
import argparse
import asyncio
from collections import defaultdict
Expand Down
6 changes: 1 addition & 5 deletions codalab/worker/worker.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
import asyncio
import logging
import io
import os
import shutil
from subprocess import PIPE, Popen
Expand Down Expand Up @@ -140,9 +139,6 @@ def __init__(

self.ws_server = ws_server

assert (
num_coroutines > 0 and type(num_coroutines) is int
), "num_coroutines must be a natural number."
self.num_coroutines = num_coroutines

self.runs = {} # type: Dict[str, RunState]
Expand Down Expand Up @@ -852,7 +848,7 @@ def netcat_fn():
break
total_data.append(data)
s.close()
reply(None, {}, io.BytesIO(b''.join(total_data)))
reply(None, {}, b''.join(total_data))
except BundleServiceException:
traceback.print_exc()
except Exception as e:
Expand Down

0 comments on commit bbe9402

Please sign in to comment.