Merge remote-tracking branch 'origin/twisha-sync-wrapper' into twisha-sync-wrapper

Author: twishabansal

packages/toolbox-core/src/toolbox_core/sync_client.py

@@ -64,7 +64,7 @@ async def __start_session() -> None:
 
         coro = __start_session()
 
-        asyncio.run_coroutine_threadsafe(coro, ToolboxSyncClient.__loop).result()
+        asyncio.run_coroutine_threadsafe(__start_session(), ToolboxSyncClient.__loop).result()
 
         if not ToolboxSyncClient.__session:
             raise ValueError("Session cannot be None.")
@@ -127,6 +127,7 @@ def load_tool(
                 for execution. The specific arguments and behavior of the callable
                 depend on the tool itself.
         """
+
         async_tool = self.__run_as_sync(
             self.__async_client.load_tool(name, auth_token_getters, bound_params)
         )
@@ -155,6 +156,7 @@ def load_toolset(
             list[ToolboxSyncTool]: A list of callables, one for each tool defined
             in the toolset.
         """
+
         async_tools = self.__run_as_sync(
             self.__async_client.load_toolset(
                 name, auth_token_getters, bound_params

packages/toolbox-core/src/toolbox_core/sync_tool.py

@@ -47,6 +47,7 @@ def __init__(
             loop: The event loop used to run asynchronous tasks.
             thread: The thread to run blocking operations in.
         """
+
         if not isinstance(async_tool, ToolboxTool):
             raise TypeError("async_tool must be an instance of ToolboxTool")
 
@@ -113,6 +114,7 @@ def add_auth_token_getters(
             A new ToolboxSyncTool instance with the specified authentication token
             getters registered.
         """
+
         new_async_tool = self.__async_tool.add_auth_token_getters(auth_token_getters)
         return ToolboxSyncTool(new_async_tool, self.__loop, self.__thread)
 
@@ -129,5 +131,6 @@ def bind_parameters(
          Returns:
              A new ToolboxSyncTool instance with the specified parameters bound.
         """
+
         new_async_tool = self.__async_tool.bind_parameters(bound_params)
         return ToolboxSyncTool(new_async_tool, self.__loop, self.__thread)

packages/toolbox-core/tests/test_sync_e2e.py

@@ -11,6 +11,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+
 import pytest
 
 from toolbox_core.sync_client import ToolboxSyncClient