fix: Fix Async Watch Method Constructor

Author: maticzav

examples/async_watch.py

@@ -0,0 +1,77 @@
+#!/usr/bin/env -S poetry run python
+
+import asyncio
+from typing import List
+
+from api import API_KEY
+from pydantic import BaseModel
+
+from browser_use import AsyncBrowserUse
+
+client = AsyncBrowserUse(api_key=API_KEY)
+
+
+# Regular Task
+async def watch_regular_task() -> None:
+    task = await client.tasks.create_task(
+        task="""
+        Find top 10 Hacker News articles and return the title and url.
+        """,
+        llm="gemini-2.5-flash",
+    )
+
+    print(f"Regular Task ID: {task.id}")
+
+    async for state in task.watch():
+        print(f"Regular Task Status: {state.status}")
+
+        if state.status == "finished":
+            print(f"Regular Task Output: {state.output}")
+            break
+
+    print("Regular Task Done")
+
+
+# Structured Output
+async def watch_structured_task() -> None:
+    class HackerNewsPost(BaseModel):
+        title: str
+        url: str
+
+    class SearchResult(BaseModel):
+        posts: List[HackerNewsPost]
+
+    task = await client.tasks.create_task(
+        task="""
+        Find top 10 Hacker News articles and return the title and url.
+        """,
+        llm="gpt-4.1",
+        schema=SearchResult,
+    )
+
+    print(f"Structured Task ID: {task.id}")
+
+    async for state in task.watch():
+        print(f"Structured Task Status: {state.status}")
+
+        if state.status == "finished":
+            print(f"Structured Task Output: {state.output}")
+
+            for post in state.parsed_output.posts:
+                print(f" - {post.title} - {post.url}")
+
+            break
+
+
+# Main
+
+
+async def main() -> None:
+    await asyncio.gather(
+        #
+        watch_regular_task(),
+        watch_structured_task(),
+    )
+
+
+asyncio.run(main())

examples/watch.py

@@ -0,0 +1,70 @@
+#!/usr/bin/env -S poetry run python
+
+from typing import List
+
+from api import API_KEY
+from pydantic import BaseModel
+
+from browser_use import BrowserUse
+
+client = BrowserUse(api_key=API_KEY)
+
+
+# Regular Task
+def watch_regular_task() -> None:
+    task = client.tasks.create_task(
+        task="""
+        Find top 10 Hacker News articles and return the title and url.
+        """,
+        llm="gemini-2.5-flash",
+    )
+
+    print(f"Task ID: {task.id}")
+
+    for state in task.watch():
+        print(f"Regular Task Status: {state.status}")
+
+        if state.status == "finished":
+            print(f"Regular Task Output: {state.output}")
+            break
+
+    print("Regular: DONE")
+
+
+watch_regular_task()
+
+
+# Structured Output
+def watch_structured_task() -> None:
+    class HackerNewsPost(BaseModel):
+        title: str
+        url: str
+
+    class SearchResult(BaseModel):
+        posts: List[HackerNewsPost]
+
+    task = client.tasks.create_task(
+        task="""
+        Find top 10 Hacker News articles and return the title and url.
+        """,
+        llm="gpt-4.1",
+        schema=SearchResult,
+    )
+
+    print(f"Task ID: {task.id}")
+
+    for state in task.watch():
+        print(f"Structured Task Status: {state.status}")
+
+        if state.status == "finished":
+            print(f"Structured Task Output: {state.output}")
+
+            for post in state.parsed_output.posts:
+                print(f" - {post.title} - {post.url}")
+
+            break
+
+    print("Structured Task Done")
+
+
+watch_structured_task()

src/browser_use/wrapper/parse.py

@@ -198,7 +198,7 @@ def stream(
         """Streams the steps of the task and closes when the task is finished."""
         return _async_stream(self._client, self.id, interval, request_options)
 
-    async def watch(
+    def watch(
         self, interval: float = 1, request_options: typing.Optional[RequestOptions] = None
     ) -> AsyncIterator[TaskView]:
         """Yields the latest task state on every change."""