chore(query): add encoding/decoding size in task client (#17965)

* chore(query): add encoding/decoding size in task client

* update

* update

* remove macos

Author: sundy-li

.github/workflows/bindings.python.yml

@@ -43,27 +43,27 @@ jobs:
           name: python-linux-${{ matrix.arch }}
           path: src/bendpy/dist/*.whl
 
-  macos:
-    if: inputs.tag
-    runs-on: macos-latest
-    strategy:
-      matrix:
-        arch:
-          - aarch64
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          fetch-depth: 0
-      - uses: ./.github/actions/build_bindings_python
-        with:
-          target: ${{ matrix.arch }}-apple-darwin
-          version: ${{ inputs.tag }}
-      - name: upload
-        if: inputs.tag
-        uses: actions/upload-artifact@v4
-        with:
-          name: python-macos-${{ matrix.arch }}
-          path: src/bendpy/dist/*.whl
+  # macos:
+  #   if: inputs.tag
+  #   runs-on: macos-latest
+  #   strategy:
+  #     matrix:
+  #       arch:
+  #         - aarch64
+  #   steps:
+  #     - uses: actions/checkout@v4
+  #       with:
+  #         fetch-depth: 0
+  #     - uses: ./.github/actions/build_bindings_python
+  #       with:
+  #         target: ${{ matrix.arch }}-apple-darwin
+  #         version: ${{ inputs.tag }}
+  #     - name: upload
+  #       if: inputs.tag
+  #       uses: actions/upload-artifact@v4
+  #       with:
+  #         name: python-macos-${{ matrix.arch }}
+  #         path: src/bendpy/dist/*.whl
 
   publish:
     if: inputs.tag

scripts/setup/dev_setup.sh

@@ -656,8 +656,8 @@ if [[ "$INSTALL_BUILD_TOOLS" == "true" ]]; then
 
 	# Any call to cargo will make rustup install the correct toolchain
 	cargo version
-	cargo install cargo-quickinstall
-	cargo quickinstall cargo-binstall
+	## install cargo-binstall
+	curl -L --proto '=https' --tlsv1.2 -sSf https://raw.githubusercontent.com/cargo-bins/cargo-binstall/main/install-from-binstall-release.sh | bash
 	cargo binstall -y sccache
 	cargo binstall -y cargo-zigbuild
 	cargo binstall -y cargo-nextest

src/common/cloud_control/src/task_client.rs

@@ -36,6 +36,11 @@ use crate::pb::ShowTasksResponse;
 
 pub(crate) const TASK_CLIENT_VERSION: &str = "v1";
 pub(crate) const TASK_CLIENT_VERSION_NAME: &str = "TASK_CLIENT_VERSION";
+/// Grpc default configuration.
+/// The hard limit of maximum message size the client or server can **send**.
+pub const MAX_ENCODING_SIZE: usize = 32 * 1024 * 1024;
+/// The hard limit of maximum message size the client or server can **receive**.
+pub const MAX_DECODING_SIZE: usize = 32 * 1024 * 1024;
 
 pub struct TaskClient {
     pub task_client: TaskServiceClient<Channel>,
@@ -44,7 +49,10 @@ pub struct TaskClient {
 impl TaskClient {
     // TODO: add auth interceptor
     pub async fn new(channel: Channel) -> Result<Arc<TaskClient>> {
-        let task_client = TaskServiceClient::new(channel);
+        let task_client = TaskServiceClient::new(channel)
+            .max_decoding_message_size(MAX_DECODING_SIZE)
+            .max_encoding_message_size(MAX_ENCODING_SIZE);
+
         Ok(Arc::new(TaskClient { task_client }))
     }