Remove debug logging statements from the Sling class to clean up output during execution.

flarco · flarco · commit c182bd64ff30 · 2025-07-15T09:40:47.000-03:00
diff --git a/sling/sling/__init__.py b/sling/sling/__init__.py
@@ -1035,9 +1035,6 @@ def _write_input_data_csv(self, stdin: IO, input_data: Any):
                     csv_writer = csv.writer(csv_buffer)
                     csv_writer.writerow(headers)
                     header_line = csv_buffer.getvalue()
-                    if self.debug:
-                        sys.stderr.write(f"Debug: Writing headers: {header_line.strip()}\n")
-                        sys.stderr.flush()
                     stdin.write(header_line.encode('utf-8'))
                     stdin.flush()
                     headers_written = True
@@ -1050,9 +1047,6 @@ def _write_input_data_csv(self, stdin: IO, input_data: Any):
                     row = [str(record.get(h, '')) for h in headers]
                     csv_writer.writerow(row)
                     csv_line = csv_buffer.getvalue()
-                    if self.debug:
-                        sys.stderr.write(f"Debug: Writing row: {csv_line.strip()}\n")
-                        sys.stderr.flush()
                     stdin.write(csv_line.encode('utf-8'))
                     stdin.flush()
             
@@ -1133,10 +1127,6 @@ def _read_output_stream_arrow_to_dicts(self, stdout: IO) -> Iterable[Dict[str, A
                         value = column[row_idx].as_py()  # Converts to native Python type
                         record[column_name] = value
                     
-                    if self.debug:
-                        sys.stderr.write(f"Debug: Arrow record: {record}\n")
-                        sys.stderr.flush()
-                    
                     yield record
                     
         except pa.lib.ArrowInvalid as e:
@@ -1164,22 +1154,14 @@ def _read_output_stream_csv(self, stdout: IO) -> Iterable[Dict[str, Any]]:
             if not first_line:
                 return
                 
-            if self.debug:
-                print(f"Debug: First line (headers): '{first_line}'")
-                
             # Parse headers
             headers = list(csv.reader([first_line]))[0]
             
-            if self.debug:
-                print(f"Debug: Parsed headers: {headers}")
-            
             # Read and parse remaining lines one by one
             for line in stdout:
                 line_str = line.decode('utf-8').strip()
                 if line_str:
                     try:
-                        if self.debug:
-                            print(f"Debug: Processing line: '{line_str}'")
                         values = list(csv.reader([line_str]))[0]
                         # Pad values if fewer than headers
                         while len(values) < len(headers):
@@ -1188,8 +1170,6 @@ def _read_output_stream_csv(self, stdout: IO) -> Iterable[Dict[str, Any]]:
                         values = values[:len(headers)]
                         # Create record dict
                         record = dict(zip(headers, values))
-                        if self.debug:
-                            print(f"Debug: Created record: {record}")
                         yield record
                     except Exception as e:
                         if self.debug:
@@ -1304,9 +1284,6 @@ def stream(self) -> Iterable[Dict[str, Any]]:
             
             # Handle input streaming
             if self.input is not None:
-                if self.debug:
-                    sys.stderr.write("Debug: Starting input streaming\n")
-                    sys.stderr.flush()
                 # Write input data directly in the main thread
                 self._write_input_data_sync(process.stdin, self.input)
             
@@ -1365,9 +1342,6 @@ def stream_arrow(self) -> pa.ipc.RecordBatchStreamReader:
             
             # Handle input streaming
             if self.input is not None:
-                if self.debug:
-                    sys.stderr.write("Debug: Starting input streaming\n")
-                    sys.stderr.flush()
                 # Write input data directly in the main thread
                 self._write_input_data_sync(process.stdin, self.input)
             
@@ -1455,9 +1429,6 @@ def run(self) -> None:
             
             # Handle input streaming if provided
             if self.input is not None:
-                if self.debug:
-                    sys.stderr.write("Debug: Starting input streaming\n")
-                    sys.stderr.flush()
                 # Write input data directly in the main thread
                 self._write_input_data_sync(process.stdin, self.input)
             
