refactor!: Introduce fully typed clients

Author: vdusek

.github/workflows/_tests.yaml

@@ -17,7 +17,7 @@ jobs:
       operating_systems: '["ubuntu-latest", "windows-latest"]'
       python_version_for_codecov: "3.14"
       operating_system_for_codecov: ubuntu-latest
-      tests_concurrency: "1"
+      tests_concurrency: "16"
 
   integration_tests:
     name: Integration tests
@@ -28,4 +28,4 @@ jobs:
       operating_systems: '["ubuntu-latest"]'
       python_version_for_codecov: "3.14"
       operating_system_for_codecov: ubuntu-latest
-      tests_concurrency: "1"
+      tests_concurrency: "16"

docs/01_overview/code/01_usage_async.py

@@ -16,6 +16,6 @@ async def main() -> None:
         return
 
     # Fetch results from the Actor run's default dataset.
-    dataset_client = apify_client.dataset(call_result['defaultDatasetId'])
+    dataset_client = apify_client.dataset(call_result.default_dataset_id)
     list_items_result = await dataset_client.list_items()
     print(f'Dataset: {list_items_result}')

docs/01_overview/code/01_usage_sync.py

@@ -16,6 +16,6 @@ def main() -> None:
         return
 
     # Fetch results from the Actor run's default dataset.
-    dataset_client = apify_client.dataset(call_result['defaultDatasetId'])
+    dataset_client = apify_client.dataset(call_result.default_dataset_id)
     list_items_result = dataset_client.list_items()
     print(f'Dataset: {list_items_result}')

docs/02_concepts/code/01_async_support.py

@@ -11,7 +11,7 @@ async def main() -> None:
 
     # Start the Actor and get the run ID
     run_result = await actor_client.start()
-    run_client = apify_client.run(run_result['id'])
+    run_client = apify_client.run(run_result.id)
     log_client = run_client.log()
 
     # Stream the logs

docs/02_concepts/code/05_retries_async.py

@@ -1,3 +1,5 @@
+from datetime import timedelta
+
 from apify_client import ApifyClientAsync
 
 TOKEN = 'MY-APIFY-TOKEN'
@@ -7,6 +9,6 @@ async def main() -> None:
     apify_client = ApifyClientAsync(
         token=TOKEN,
         max_retries=8,
-        min_delay_between_retries_millis=500,  # 0.5s
-        timeout_secs=360,  # 6 mins
+        min_delay_between_retries=timedelta(milliseconds=500),  # 0.5s
+        timeout=timedelta(seconds=360),  # 6 mins
     )

docs/02_concepts/code/05_retries_sync.py

@@ -1,3 +1,5 @@
+from datetime import timedelta
+
 from apify_client import ApifyClient
 
 TOKEN = 'MY-APIFY-TOKEN'
@@ -7,6 +9,6 @@ async def main() -> None:
     apify_client = ApifyClient(
         token=TOKEN,
         max_retries=8,
-        min_delay_between_retries_millis=500,  # 0.5s
-        timeout_secs=360,  # 6 mins
+        min_delay_between_retries=timedelta(milliseconds=500),  # 0.5s
+        timeout=timedelta(seconds=360),  # 6 mins
     )

docs/03_examples/code/01_input_async.py

@@ -1,4 +1,5 @@
 import asyncio
+from datetime import timedelta
 
 from apify_client import ApifyClientAsync
 
@@ -16,7 +17,9 @@ async def main() -> None:
 
     # Run the Actor and wait for it to finish up to 60 seconds.
     # Input is not persisted for next runs.
-    run_result = await actor_client.call(run_input=input_data, timeout_secs=60)
+    run_result = await actor_client.call(
+        run_input=input_data, timeout=timedelta(seconds=60)
+    )
 
 
 if __name__ == '__main__':

docs/03_examples/code/01_input_sync.py

@@ -1,3 +1,5 @@
+from datetime import timedelta
+
 from apify_client import ApifyClient
 
 TOKEN = 'MY-APIFY-TOKEN'
@@ -14,7 +16,7 @@ def main() -> None:
 
     # Run the Actor and wait for it to finish up to 60 seconds.
     # Input is not persisted for next runs.
-    run_result = actor_client.call(run_input=input_data, timeout_secs=60)
+    run_result = actor_client.call(run_input=input_data, timeout=timedelta(seconds=60))
 
 
 if __name__ == '__main__':

docs/03_examples/code/02_tasks_async.py

@@ -1,22 +1,22 @@
 import asyncio
 
 from apify_client import ApifyClientAsync
-from apify_client.clients.resource_clients import TaskClientAsync
+from apify_client._models import Run, Task
+from apify_client._resource_clients import TaskClientAsync
 
 TOKEN = 'MY-APIFY-TOKEN'
 HASHTAGS = ['zebra', 'lion', 'hippo']
 
 
-async def run_apify_task(client: TaskClientAsync) -> dict:
-    result = await client.call()
-    return result or {}
+async def run_apify_task(client: TaskClientAsync) -> Run | None:
+    return await client.call()
 
 
 async def main() -> None:
     apify_client = ApifyClientAsync(token=TOKEN)
 
     # Create Apify tasks
-    apify_tasks = list[dict]()
+    apify_tasks = list[Task]()
     apify_tasks_client = apify_client.tasks()
 
     for hashtag in HASHTAGS:
@@ -34,7 +34,7 @@ async def main() -> None:
     apify_task_clients = list[TaskClientAsync]()
 
     for apify_task in apify_tasks:
-        task_id = apify_task['id']
+        task_id = apify_task.id
         apify_task_client = apify_client.task(task_id)
         apify_task_clients.append(apify_task_client)
 

docs/03_examples/code/02_tasks_sync.py

@@ -1,20 +1,20 @@
 from apify_client import ApifyClient
-from apify_client.clients.resource_clients import TaskClient
+from apify_client._models import Run, Task
+from apify_client._resource_clients import TaskClient
 
 TOKEN = 'MY-APIFY-TOKEN'
 HASHTAGS = ['zebra', 'lion', 'hippo']
 
 
-def run_apify_task(client: TaskClient) -> dict:
-    result = client.call()
-    return result or {}
+def run_apify_task(client: TaskClient) -> Run | None:
+    return client.call()
 
 
 def main() -> None:
     apify_client = ApifyClient(token=TOKEN)
 
     # Create Apify tasks
-    apify_tasks = list[dict]()
+    apify_tasks = list[Task]()
     apify_tasks_client = apify_client.tasks()
 
     for hashtag in HASHTAGS:
@@ -32,18 +32,19 @@ def main() -> None:
     apify_task_clients = list[TaskClient]()
 
     for apify_task in apify_tasks:
-        task_id = apify_task['id']
+        task_id = apify_task.id
         apify_task_client = apify_client.task(task_id)
         apify_task_clients.append(apify_task_client)
 
     print('Task clients created:', apify_task_clients)
 
     # Execute Apify tasks
-    task_run_results = list[dict]()
+    task_run_results = list[Run]()
 
     for client in apify_task_clients:
         result = run_apify_task(client)
-        task_run_results.append(result)
+        if result is not None:
+            task_run_results.append(result)
 
     print('Task results:', task_run_results)