Bump version to 0.0.31

alpha-unito · May 29, 2021 · 8d4f0ac · 8d4f0ac
1 parent 71b669a
commit 8d4f0ac
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 2 deletions.
diff --git a/streamflow/config/schemas/v1.0/helm2.json b/streamflow/config/schemas/v1.0/helm2.json
@@ -83,7 +83,7 @@
     "maxConcurrentConnections": {
       "type": "integer",
       "description": "Maximum number of concurrent connections to open for a single Kubernetes client",
-      "default": 10
+      "default": 4096
     },
     "namespace": {
       "type": "string",

diff --git a/streamflow/config/schemas/v1.0/helm3.json b/streamflow/config/schemas/v1.0/helm3.json
@@ -71,6 +71,11 @@
       "type": "string",
       "description": "Absolute path of the kubeconfig file to be used"
     },
+    "maxConcurrentConnections": {
+      "type": "integer",
+      "description": "Maximum number of concurrent connections to open for a single Kubernetes client",
+      "default": 4096
+    },
     "namespace": {
       "type": "string",
       "description": "Namespace to install the release into",

diff --git a/streamflow/deployment/connector/queue_manager.py b/streamflow/deployment/connector/queue_manager.py
@@ -83,6 +83,19 @@ async def get_available_resources(self, service: Text) -> MutableMapping[Text, R
             resources[name] = Resource(name, self.hostname)
         return resources
 
+    async def _copy_remote_to_remote(self,
+                                     src: Text,
+                                     dst: Text,
+                                     resources: MutableSequence[Text],
+                                     source_remote: Text,
+                                     read_only: bool = False) -> None:
+        return await super()._copy_remote_to_remote(
+            src=src,
+            dst=dst,
+            resources=[source_remote],
+            source_remote=source_remote,
+            read_only=read_only)
+
     async def _run(self,
                    resource: Text,
                    command: MutableSequence[Text],

diff --git a/streamflow/version.py b/streamflow/version.py
@@ -1 +1 @@
-VERSION = "0.0.30"
+VERSION = "0.0.31"