Fix(integrations-service): Change to asynchronous methods

integrations-service/integrations/routers/execution/execute.py

@@ -7,12 +7,12 @@
 
 
 @router.post("/execute/{provider}", tags=["execution"])
-def execute(
+async def execute(
     provider: IdentifierName,
     data: ExecutionRequest,
 ) -> ExecutionResponse:
     try:
-        return execute_integration(
+        return await execute_integration(
             provider=provider, arguments=data.arguments, setup=data.setup
         )
     except ValueError as e:

integrations-service/integrations/utils/execute_integration.py

@@ -5,7 +5,7 @@
 from ..providers import providers
 
 
-def execute_integration(
+async def execute_integration(
     provider: IdentifierName,
     arguments: ExecutionArguments,
     method: IdentifierName | None = None,
@@ -32,6 +32,6 @@ def execute_integration(
     parsed_arguments = arguments_class(**arguments.model_dump())
 
     if setup:
-        return execution_function(setup=setup, arguments=parsed_arguments)
+        return await execution_function(setup=setup, arguments=parsed_arguments)
     else:
         return execution_function(arguments=parsed_arguments)

integrations-service/integrations/utils/integrations/brave.py

@@ -3,7 +3,7 @@
 from ...models import BraveSearchArguments, BraveSearchOutput, BraveSearchSetup
 
 
-def search(
+async def search(
     setup: BraveSearchSetup, arguments: BraveSearchArguments
 ) -> BraveSearchOutput:
     """

integrations-service/integrations/utils/integrations/browserbase.py

@@ -3,7 +3,7 @@
 from ...models import BrowserBaseLoadArguments, BrowserBaseLoadOutput, BrowserBaseSetup
 
 
-def load(
+async def load(
     setup: BrowserBaseSetup, arguments: BrowserBaseLoadArguments
 ) -> BrowserBaseLoadOutput:
     """

integrations-service/integrations/utils/integrations/hacker_news.py

@@ -3,7 +3,7 @@
 from ...models import HackerNewsFetchArguments, HackerNewsFetchOutput
 
 
-def fetch(arguments: HackerNewsFetchArguments) -> HackerNewsFetchOutput:
+async def fetch(arguments: HackerNewsFetchArguments) -> HackerNewsFetchOutput:
     """
     Fetches and formats content from a Hacker News thread using the provided URL.
     """

integrations-service/integrations/utils/integrations/spider.py

@@ -3,7 +3,7 @@
 from ...models import SpiderFetchArguments, SpiderFetchOutput, SpiderSetup
 
 
-def crawl(setup: SpiderSetup, arguments: SpiderFetchArguments) -> SpiderFetchOutput:
+async def crawl(setup: SpiderSetup, arguments: SpiderFetchArguments) -> SpiderFetchOutput:
     """
     Fetches data from a specified URL.
     """

integrations-service/integrations/utils/integrations/weather.py

@@ -3,7 +3,7 @@
 from ...models import WeatherGetArguments, WeatherGetOutput, WeatherSetup
 
 
-def get(setup: WeatherSetup, arguments: WeatherGetArguments) -> WeatherGetOutput:
+async def get(setup: WeatherSetup, arguments: WeatherGetArguments) -> WeatherGetOutput:
     """
     Fetches weather data for a specified location using OpenWeatherMap API.
     """