This is an automated email from the ASF dual-hosted git repository.

brandonwilliams pushed a commit to branch CASSANDRA-18353-4.1
in repository https://gitbox.apache.org/repos/asf/cassandra.git

commit 14de8689aef9899da8628a7d1fefd95345d1c800
Author: Brandon Williams <[email protected]>
AuthorDate: Tue Mar 21 16:07:49 2023 -0500

    Restore COPY ... TO STDOUT behavior
---
 pylib/cqlshlib/copyutil.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/pylib/cqlshlib/copyutil.py b/pylib/cqlshlib/copyutil.py
index 31c881c595..3344c00ec1 100644
--- a/pylib/cqlshlib/copyutil.py
+++ b/pylib/cqlshlib/copyutil.py
@@ -85,6 +85,10 @@ def printmsg(msg, eol='\n'):
     sys.stdout.write(eol)
     sys.stdout.flush()
 
+# Keep arguments in sync with printmsg
+def swallowmsg(msg, eol='\n'):
+    None
+
 
 class OneWayPipe(object):
     """
@@ -249,7 +253,7 @@ class CopyTask(object):
             DEBUG = True
 
         # do not display messages when exporting to STDOUT unless --debug is 
set
-        self.printmsg = printmsg if self.fname is not None or direction == 
'from' or DEBUG else None
+        self.printmsg = printmsg if self.fname is not None or direction == 
'from' or DEBUG else swallowmsg
         self.options = self.parse_options(opts, direction)
 
         self.num_processes = self.options.copy['numprocesses']


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to