Merge branch 'remove-s3-bucket-polling' of https://github.com/ssl-hep/ServiceX_frontend into remove-s3-bucket-polling

Author: MattShirley

servicex/query_core.py

@@ -575,7 +575,7 @@ async def get_signed_url(
                     for file in files:
                         filename = file.filename
 
-                        if filename != '' and filename not in files_seen:
+                        if filename != "" and filename not in files_seen:
                             if signed_urls_only:
                                 download_tasks.append(
                                     loop.create_task(

servicex/servicex_adapter.py

@@ -49,6 +49,7 @@
 class AuthorizationError(BaseException):
     pass
 
+
 @dataclass
 class ServiceXFile:
     filename: str

tests/test_servicex_adapter.py

@@ -509,12 +509,14 @@ async def test_get_authorization(servicex):
 @patch("servicex.servicex_adapter.ClientSession.get")
 async def test_get_transformation_results_success(get, servicex):
     get.return_value.__aenter__.return_value.status = 200
-    get.return_value.__aenter__.return_value.json = AsyncMock(return_value={
-        "results": [
-            {"file-path": "file1.txt"},
-            {"file-path": "file2.txt"},
-        ]
-    })
+    get.return_value.__aenter__.return_value.json = AsyncMock(
+        return_value={
+            "results": [
+                {"file-path": "file1.txt"},
+                {"file-path": "file2.txt"},
+            ]
+        }
+    )
 
     print(get)
 

tests/test_servicex_dataset.py

@@ -208,7 +208,9 @@ async def test_submit(mocker):
     servicex.submit_transform = AsyncMock()
     servicex.submit_transform.return_value = {"request_id": '123-456-789"'}
 
-    servicex.get_transformation_results = AsyncMock(side_effect=[[file1], [file1, file2]])
+    servicex.get_transformation_results = AsyncMock(
+        side_effect=[[file1], [file1, file2]]
+    )
 
     servicex.get_transform_status = AsyncMock()
     servicex.get_transform_status.side_effect = [