fix pre-commit checks

Author: anurag-atlan

application_sdk/outputs/__init__.py

@@ -25,7 +25,7 @@
 from temporalio import activity
 
 from application_sdk.activities.common.models import ActivityStatistics
-from application_sdk.activities.common.utils import get_object_store_prefix, build_output_path
+from application_sdk.activities.common.utils import get_object_store_prefix
 from application_sdk.common.dataframe_utils import is_empty_dataframe
 from application_sdk.observability.logger_adaptor import get_logger
 from application_sdk.observability.metrics_adaptor import MetricType
@@ -391,7 +391,9 @@ async def _flush_buffer(self, chunk: "pd.DataFrame", chunk_part: int):
             logger.error(f"Error flushing buffer to files: {str(e)}")
             raise e
 
-    async def write_statistics(self, typename: Optional[str] = None) -> Optional[Dict[str, Any]]:
+    async def write_statistics(
+        self, typename: Optional[str] = None
+    ) -> Optional[Dict[str, Any]]:
         """Write statistics about the output to a JSON file.
 
         This method writes statistics including total record count and chunk count

tests/unit/outputs/test_output.py

@@ -141,7 +141,9 @@ async def test_write_statistics_success(self):
             }
             expected_stats_dir = os.path.join("/test/path", "statistics")
             mock_makedirs.assert_called_once_with(expected_stats_dir, exist_ok=True)
-            expected_file_path = os.path.join(expected_stats_dir, "statistics.json.ignore")
+            expected_file_path = os.path.join(
+                expected_stats_dir, "statistics.json.ignore"
+            )
             mock_file.assert_called_once_with(expected_file_path, "wb")
             mock_orjson.assert_called_once_with(
                 {
@@ -154,7 +156,9 @@ async def test_write_statistics_success(self):
             mock_push.assert_awaited_once()
             upload_kwargs = mock_push.await_args.kwargs  # type: ignore[attr-defined]
             assert upload_kwargs["source"] == expected_file_path
-            assert upload_kwargs["destination"] == "path/statistics/statistics.json.ignore"
+            assert (
+                upload_kwargs["destination"] == "path/statistics/statistics.json.ignore"
+            )
 
     @pytest.mark.asyncio
     async def test_write_statistics_error(self):