Resolving int test bugs

pyproject.toml

@@ -29,7 +29,7 @@ include = [
 [tool.poetry.dependencies]
 python = ">=3.8,<3.13"
 realit_singer_python = "^5.0.0"
-boto3 = "1.34.158"
+boto3 = "1.35.8"
 realit-singer-encodings = ">=2.1.0"
 voluptuous = "0.14.2"
 ujson = ">=5.4.0"

run_integration_tests.py

@@ -45,7 +45,6 @@ def run_command(command, env=None):
     container_name = "minio_server"
     result = is_container_running(container_name)
     print(result)
-    print(os.environ)
     if result or 'GITHUB_ACTIONS' in os.environ:
         rc = run_command(['poetry', 'run', 'pytest', 'tests/integration'],env=os.environ)
         raise SystemExit(rc)

tests/integration/test_tap_s3_csv.py

@@ -5,6 +5,7 @@
 import os.path
 import random
 import unittest
+import sys
 from copy import deepcopy
 
 import boto3
@@ -149,15 +150,18 @@ def setUpClass(cls) -> None:
 
     @classmethod
     def tearDownClass(cls) -> None:
-        s3_client = boto3.client("s3")
+        # Remove test file from bucket
+        s3_client = boto3.client(
+            "s3", endpoint_url=cls.config["aws_endpoint_url"]
+        )
         s3_client.delete_object(Bucket=cls.config["bucket"], Key=cls.obj_name)
 
     def test_discovery(self):
-        f = io.StringIO()
-        with contextlib.redirect_stdout(f):
+        file_buffer = io.StringIO()
+        with contextlib.redirect_stdout(file_buffer):
             do_discover(self.config)
 
-        catalog = ujson.loads(f.getvalue())
+        catalog = ujson.loads(file_buffer.getvalue())
 
         self.assertIsInstance(catalog, dict)
         self.assertEqual(1, len(catalog["streams"]))
@@ -188,12 +192,14 @@ def test_sync(self):
         # set stream to selected
         catalog["streams"][0]["metadata"][0]["metadata"]["selected"] = True
 
-        f = io.StringIO()
-        with contextlib.redirect_stdout(f):
+        file_buffer = io.TextIOWrapper(io.BytesIO(), sys.stdout.encoding)
+        with contextlib.redirect_stdout(file_buffer):
             do_sync(self.config, catalog, {})
 
+        # Position at the start of the buffer
+        file_buffer.seek(0)
         lines = [
-            ujson.loads(line) for line in f.getvalue().strip().splitlines()
+            ujson.loads(line) for line in file_buffer.read().strip().splitlines()
         ]
 
         self.assertDictEqual({"type": "STATE", "value": {}}, lines[0])