diff --git a/go/net/ssh/ssh_client.go b/go/net/ssh/ssh_client.go
index 4e3cab6..1c52484 100644
--- a/go/net/ssh/ssh_client.go
+++ b/go/net/ssh/ssh_client.go
@@ -102,7 +102,7 @@
 }
 
 func (p *directConn) Upload(ctx context.Context, targetPath string, src io.Reader) error {
-	sc, err := sftp.NewClient(p.cl)
+	sc, err := sftp.NewClient(p.cl, sftp.UseConcurrentWrites(true), sftp.MaxConcurrentRequestsPerFile(1024))
 	if err != nil {
 		return fmt.Errorf("while building sftp client: %w", err)
 	}
@@ -116,7 +116,7 @@
 	doneC := make(chan error, 1)
 
 	go func() {
-		_, err := io.Copy(df, src)
+		_, err := df.ReadFromWithConcurrency(src, 0)
 		df.Close()
 		doneC <- err
 	}()