Hide debug messages

oeway · Aug 24, 2024 · e4850b4 · e4850b4
1 parent 15819db
commit e4850b4
Show file tree

Hide file tree

Showing 7 changed files with 29 additions and 29 deletions.
diff --git a/javascript/package-lock.json b/javascript/package-lock.json
diff --git a/javascript/package.json b/javascript/package.json
@@ -1,6 +1,6 @@
 {
  "name": "hypha-rpc",
- "version": "0.20.28",
+ "version": "0.20.29",
  "description": "Hypha RPC client for connecting to Hypha server for data management and AI model serving.",
  "main": "index.js",
  "types": "index.d.ts",

diff --git a/javascript/src/rpc.js b/javascript/src/rpc.js
@@ -337,7 +337,7 @@ export class RPC extends MessageEmitter {
  await manager.registerService(serviceInfo);
  }
  } else {
- console.debug("Connection established", connectionInfo);
+ // console.debug("Connection established", connectionInfo);
  }
  if (connectionInfo) {
  if (connectionInfo.public_base_url) {
@@ -445,7 +445,7 @@ export class RPC extends MessageEmitter {
  throw new Error(`Message with key ${key} does not exists.`);
  }
  cache[key] = concatArrayBuffers(cache[key]);
- console.debug(`Processing message ${key} (bytes=${cache[key].byteLength})`);
+ // console.debug(`Processing message ${key} (bytes=${cache[key].byteLength})`);
  let unpacker = decodeMulti(cache[key]);
  const { done, value } = unpacker.next();
  const main = value;
@@ -462,10 +462,10 @@ export class RPC extends MessageEmitter {
  Object.assign(main, extra.value);
  }
  this._fire(main["type"], main);
- console.debug(
- this._client_id,
- `Processed message ${key} (bytes=${cache[key].byteLength})`,
- );
+ // console.debug(
+ //  this._client_id,
+ //  `Processed message ${key} (bytes=${cache[key].byteLength})`,
+ // );
  delete cache[key];
  }
 
@@ -904,9 +904,9 @@ export class RPC extends MessageEmitter {
  data.slice(start_byte, start_byte + CHUNK_SIZE),
  !!session_id,
  );
- console.debug(
- `Sending chunk ${idx + 1}/${chunk_num} (${total_size} bytes)`,
- );
+ // console.debug(
+ //  `Sending chunk ${idx + 1}/${chunk_num} (${total_size} bytes)`,
+ // );
  }
  // console.log(`All chunks sent (${chunk_num})`);
  await message_cache.process(message_id, !!session_id);
@@ -1066,7 +1066,7 @@ export class RPC extends MessageEmitter {
  ._send_chunks(message_package, target_id, remote_parent)
  .then(function () {
  if (timer) {
- console.debug(`Start watchdog timer.`);
+ // console.debug(`Start watchdog timer.`);
  // Only start the timer after we send the message successfully
  timer.start();
  }
@@ -1150,7 +1150,7 @@ export class RPC extends MessageEmitter {
  if (promise.heartbeat && promise.interval) {
  async function heartbeat() {
  try {
- console.debug("Reset heartbeat timer: " + data.method);
+ // console.debug("Reset heartbeat timer: " + data.method);
  await promise.heartbeat();
  } catch (err) {
  console.error(err);
@@ -1165,7 +1165,7 @@ export class RPC extends MessageEmitter {
  try {
  method = indexObject(this._object_store, data["method"]);
  } catch (e) {
- console.debug("Failed to find method", method_name, this._client_id, e);
+ // console.debug("Failed to find method", method_name, this._client_id, e);
  throw new Error(
  `Method not found: ${method_name} at ${this._client_id}`,
  );
@@ -1255,7 +1255,7 @@ export class RPC extends MessageEmitter {
  `Runtime Error: Invalid number of arguments for method ${method_name}, expected ${method.length} but got ${args.length}`,
  );
  }
- console.debug("Executing method: " + method_name);
+ // console.debug("Executing method: " + method_name);
  if (data.promise) {
  const result = method.apply(null, args);
  if (result instanceof Promise) {
@@ -1279,7 +1279,7 @@ export class RPC extends MessageEmitter {
  } catch (err) {
  if (reject) {
  reject(err);
- console.debug("Error during calling method: ", err);
+ // console.debug("Error during calling method: ", err);
  } else {
  console.error("Error during calling method: ", err);
  }
@@ -1351,11 +1351,11 @@ export class RPC extends MessageEmitter {
  const _server = aObject.__rpc_object__._rserver || this._server_base_url;
  if (_server === this._server_base_url) {
  return aObject.__rpc_object__;
- } else {
- console.debug(
- `Encoding remote function from a different server ${_server}, current server: ${this._server_base_url}`,
- );
- }
+ } // else {
+ //  console.debug(
+ //  `Encoding remote function from a different server ${_server}, current server: ${this._server_base_url}`,
+ //  );
+ // }
  }
 
  let bObject;

diff --git a/javascript/src/websocket-client.js b/javascript/src/websocket-client.js
@@ -730,7 +730,7 @@ export class LocalWebSocket {
  (event) => {
  const { type, data, to } = event.data;
  if (to !== this.client_id) {
- console.debug("message not for me", to, this.client_id);
+ // console.debug("message not for me", to, this.client_id);
  return;
  }
  switch (type) {

diff --git a/python/hypha_rpc/VERSION b/python/hypha_rpc/VERSION
@@ -1,3 +1,3 @@
 {
- "version": "0.20.28"
+ "version": "0.20.29"
 }
diff --git a/python/hypha_rpc/rpc.py b/python/hypha_rpc/rpc.py
@@ -1316,10 +1316,10 @@ def _encode(
  _server = a_object.__rpc_object__.get("_rserver", self._server_base_url)
  if _server == self._server_base_url:
  return a_object.__rpc_object__
- else:
- logger.debug(
- f"Encoding remote function from a different server {_server}, current server: {self._server_base_url}"
- )
+ # else:
+ #  logger.debug(
+ #  f"Encoding remote function from a different server {_server}, current server: {self._server_base_url}"
+ #  )
 
  # skip if already encoded
  if isinstance(a_object, dict) and "_rtype" in a_object:

diff --git a/python/pyproject.toml b/python/pyproject.toml
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "hypha_rpc"
-version = "0.20.28"
+version = "0.20.29"
 description = "Hypha RPC client for connecting to Hypha server for data management and AI model serving"
 readme = "README.md"
 requires-python = ">=3.6"