Fixed sync calls

Author: vzucher

README.md

@@ -607,8 +607,7 @@ brightdata --help
 
 # Scrape Amazon product (URL is positional argument)
 brightdata scrape amazon products \
-  "https://amazon.com/dp/B0CRMZHDG8" \
-  --output-format json
+  "https://amazon.com/dp/B0CRMZHDG8"
 
 # Search LinkedIn jobs
 brightdata search linkedin jobs \
@@ -625,7 +624,7 @@ brightdata search google \
 # Generic web scraping (URL is positional argument)
 brightdata scrape generic \
   "https://example.com" \
-  --output-format pretty
+  --response-format pretty
 ```
 
 ### Available Commands

pyproject.toml

@@ -61,4 +61,7 @@ python_files = ["test_*.py"]
 python_classes = ["Test*"]
 python_functions = ["test_*"]
 asyncio_mode = "auto"
+markers = [
+    "slow: marks tests as slow (deselect with '-m \"not slow\"')",
+]
 

src/brightdata/scrapers/amazon/scraper.py

@@ -107,7 +107,10 @@ def products(
             ...     timeout=240
             ... )
         """
-        return asyncio.run(self.products_async(url, timeout=timeout))
+        async def _run():
+            async with self.engine:
+                return await self.products_async(url, timeout=timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # PRODUCTS TRIGGER/STATUS/FETCH (Manual Control)
@@ -280,7 +283,10 @@ def reviews(
             ...     timeout=240
             ... )
         """
-        return asyncio.run(self.reviews_async(url, pastDays, keyWord, numOfReviews, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.reviews_async(url, pastDays, keyWord, numOfReviews, timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # REVIEWS TRIGGER/STATUS/FETCH (Manual Control)
@@ -394,7 +400,10 @@ def sellers(
         
         See sellers_async() for documentation.
         """
-        return asyncio.run(self.sellers_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.sellers_async(url, timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # SELLERS TRIGGER/STATUS/FETCH (Manual Control)

src/brightdata/scrapers/chatgpt/scraper.py

@@ -121,7 +121,10 @@ def prompt(
         Example:
             >>> result = scraper.prompt("Explain Python asyncio")
         """
-        return asyncio.run(self.prompt_async(prompt, **kwargs))
+        async def _run():
+            async with self.engine:
+                return await self.prompt_async(prompt, **kwargs)
+        return asyncio.run(_run())
 
     # ============================================================================
     # PROMPT TRIGGER/STATUS/FETCH (Manual Control)
@@ -267,7 +270,10 @@ def prompts(
         
         See prompts_async() for full documentation.
         """
-        return asyncio.run(self.prompts_async(prompts, **kwargs))
+        async def _run():
+            async with self.engine:
+                return await self.prompts_async(prompts, **kwargs)
+        return asyncio.run(_run())
 
     # ============================================================================
     # PROMPTS TRIGGER/STATUS/FETCH (Manual Control for batch)

src/brightdata/scrapers/facebook/scraper.py

@@ -129,9 +129,12 @@ def posts_by_profile(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect posts from Facebook profile URL (sync wrapper)."""
-        return asyncio.run(self.posts_by_profile_async(
-            url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
-        ))
+        async def _run():
+            async with self.engine:
+                return await self.posts_by_profile_async(
+                    url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
+                )
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -253,9 +256,12 @@ def posts_by_group(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect posts from Facebook group URL (sync wrapper)."""
-        return asyncio.run(self.posts_by_group_async(
-            url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
-        ))
+        async def _run():
+            async with self.engine:
+                return await self.posts_by_group_async(
+                    url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
+                )
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -339,7 +345,10 @@ def posts_by_url(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect detailed data from specific Facebook post URLs (sync wrapper)."""
-        return asyncio.run(self.posts_by_url_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.posts_by_url_async(url, timeout)
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -434,9 +443,12 @@ def comments(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect comments from Facebook post URL (sync wrapper)."""
-        return asyncio.run(self.comments_async(
-            url, num_of_comments, comments_to_not_include, start_date, end_date, timeout
-        ))
+        async def _run():
+            async with self.engine:
+                return await self.comments_async(
+                    url, num_of_comments, comments_to_not_include, start_date, end_date, timeout
+                )
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -537,9 +549,12 @@ def reels(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect reels from Facebook profile URL (sync wrapper)."""
-        return asyncio.run(self.reels_async(
-            url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
-        ))
+        async def _run():
+            async with self.engine:
+                return await self.reels_async(
+                    url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
+                )
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 

src/brightdata/scrapers/instagram/scraper.py

@@ -109,7 +109,10 @@ def profiles(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect profile details from Instagram profile URL (sync wrapper)."""
-        return asyncio.run(self.profiles_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.profiles_async(url, timeout)
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -185,7 +188,10 @@ def posts(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect detailed data from Instagram post URLs (sync wrapper)."""
-        return asyncio.run(self.posts_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.posts_async(url, timeout)
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -261,7 +267,10 @@ def comments(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect comments from Instagram post URL (sync wrapper)."""
-        return asyncio.run(self.comments_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.comments_async(url, timeout)
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -337,7 +346,10 @@ def reels(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Collect detailed data from Instagram reel URLs (sync wrapper)."""
-        return asyncio.run(self.reels_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.reels_async(url, timeout)
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 

src/brightdata/scrapers/instagram/search.py

@@ -128,9 +128,12 @@ def posts(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Discover recent Instagram posts from a public profile (sync wrapper)."""
-        return asyncio.run(self.posts_async(
-            url, num_of_posts, posts_to_not_include, start_date, end_date, post_type, timeout
-        ))
+        async def _run():
+            async with self.engine:
+                return await self.posts_async(
+                    url, num_of_posts, posts_to_not_include, start_date, end_date, post_type, timeout
+                )
+        return asyncio.run(_run())
 
     # ============================================================================
     # REELS DISCOVERY (by profile or search URL with filters)
@@ -197,9 +200,12 @@ def reels(
         timeout: int = DEFAULT_TIMEOUT_MEDIUM,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Discover Instagram Reels from profile or search URL (sync wrapper)."""
-        return asyncio.run(self.reels_async(
-            url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
-        ))
+        async def _run():
+            async with self.engine:
+                return await self.reels_async(
+                    url, num_of_posts, posts_to_not_include, start_date, end_date, timeout
+                )
+        return asyncio.run(_run())
 
     # ============================================================================
     # CORE DISCOVERY LOGIC

src/brightdata/scrapers/linkedin/scraper.py

@@ -112,7 +112,10 @@ def posts(
         
         See posts_async() for documentation.
         """
-        return asyncio.run(self.posts_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.posts_async(url, timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # POSTS TRIGGER/STATUS/FETCH (Manual Control)
@@ -191,7 +194,10 @@ def jobs(
         timeout: int = DEFAULT_TIMEOUT_SHORT,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Scrape LinkedIn jobs (sync wrapper)."""
-        return asyncio.run(self.jobs_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.jobs_async(url, timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # JOBS TRIGGER/STATUS/FETCH (Manual Control)
@@ -270,7 +276,10 @@ def profiles(
         timeout: int = DEFAULT_TIMEOUT_SHORT,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Scrape LinkedIn profiles (sync wrapper)."""
-        return asyncio.run(self.profiles_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.profiles_async(url, timeout)
+        return asyncio.run(_run())
 
     # --- Trigger Interface (Manual Control) ---
 
@@ -346,7 +355,10 @@ def companies(
         timeout: int = DEFAULT_TIMEOUT_SHORT,
     ) -> Union[ScrapeResult, List[ScrapeResult]]:
         """Scrape LinkedIn companies (sync wrapper)."""
-        return asyncio.run(self.companies_async(url, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.companies_async(url, timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # COMPANIES TRIGGER/STATUS/FETCH (Manual Control)

src/brightdata/scrapers/linkedin/search.py

@@ -128,7 +128,10 @@ def posts(
         
         See posts_async() for documentation.
         """
-        return asyncio.run(self.posts_async(profile_url, start_date, end_date, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.posts_async(profile_url, start_date, end_date, timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # PROFILES DISCOVERY (by name)
@@ -188,7 +191,10 @@ def profiles(
         
         See profiles_async() for documentation.
         """
-        return asyncio.run(self.profiles_async(firstName, lastName, timeout))
+        async def _run():
+            async with self.engine:
+                return await self.profiles_async(firstName, lastName, timeout)
+        return asyncio.run(_run())
 
     # ============================================================================
     # JOBS DISCOVERY (by keyword + extensive filters)
@@ -325,19 +331,22 @@ def jobs(
             ...     remote=True
             ... )
         """
-        return asyncio.run(self.jobs_async(
-            url=url,
-            location=location,
-            keyword=keyword,
-            country=country,
-            timeRange=timeRange,
-            jobType=jobType,
-            experienceLevel=experienceLevel,
-            remote=remote,
-            company=company,
-            locationRadius=locationRadius,
-            timeout=timeout
-        ))
+        async def _run():
+            async with self.engine:
+                return await self.jobs_async(
+                    url=url,
+                    location=location,
+                    keyword=keyword,
+                    country=country,
+                    timeRange=timeRange,
+                    jobType=jobType,
+                    experienceLevel=experienceLevel,
+                    remote=remote,
+                    company=company,
+                    locationRadius=locationRadius,
+                    timeout=timeout
+                )
+        return asyncio.run(_run())
 
     # ============================================================================
     # HELPER METHODS