Update

Author: vdusek

src/apify_client/_models.py

@@ -1,6 +1,6 @@
 # generated by datamodel-codegen:
 #   filename:  openapi.json
-#   timestamp: 2025-12-28T21:31:16+00:00
+#   timestamp: 2026-01-02T15:04:48+00:00
 
 from __future__ import annotations
 
@@ -197,13 +197,15 @@ class ActorStats(BaseModel):
     total_users7_days: Annotated[float, Field(alias='totalUsers7Days', examples=[2])]
     total_users30_days: Annotated[float, Field(alias='totalUsers30Days', examples=[6])]
     total_users90_days: Annotated[float, Field(alias='totalUsers90Days', examples=[6])]
-    total_metamorphs: Annotated[float, Field(alias='totalMetamorphs', examples=[2])]
-    last_run_started_at: Annotated[str, Field(alias='lastRunStartedAt', examples=['2019-07-08T14:01:05.546Z'])]
+    total_metamorphs: Annotated[float | None, Field(alias='totalMetamorphs', examples=[2])] = None
+    last_run_started_at: Annotated[
+        str | None, Field(alias='lastRunStartedAt', examples=['2019-07-08T14:01:05.546Z'])
+    ] = None
 
 
 class ExampleRunInput(BaseModel):
-    body: Annotated[str | None, Field(examples=[{'helloWorld': 123}])] = None
-    content_type: Annotated[str | None, Field(alias='contentType', examples=['application/json; charset=utf-8'])] = None
+    body: Annotated[str, Field(examples=[{'helloWorld': 123}])]
+    content_type: Annotated[str, Field(alias='contentType', examples=['application/json; charset=utf-8'])]
 
 
 class Latest(BaseModel):
@@ -242,7 +244,7 @@ class Actor(BaseModel):
     default_run_options: Annotated[DefaultRunOptions, Field(alias='defaultRunOptions')]
     example_run_input: Annotated[Any | ExampleRunInput | None, Field(alias='exampleRunInput')] = None
     is_deprecated: Annotated[bool | None, Field(alias='isDeprecated', examples=[False])] = None
-    deployment_key: Annotated[str, Field(alias='deploymentKey', examples=['ssh-rsa AAAA ...'])]
+    deployment_key: Annotated[str | None, Field(alias='deploymentKey', examples=['ssh-rsa AAAA ...'])] = None
     title: Annotated[str | None, Field(examples=['My Actor'])] = None
     tagged_builds: Annotated[Any | TaggedBuilds | None, Field(alias='taggedBuilds')] = None
 
@@ -416,7 +418,7 @@ class GetListOfWebhooksResponse(BaseModel):
 
 class BuildsMeta(BaseModel):
     origin: Annotated[str, Field(examples=['WEB'])]
-    client_ip: Annotated[str, Field(alias='clientIp', examples=['172.234.12.34'])]
+    client_ip: Annotated[str | None, Field(alias='clientIp', examples=['172.234.12.34'])] = None
     user_agent: Annotated[str, Field(alias='userAgent', examples=['Mozilla/5.0 (iPad)'])]
 
 
@@ -444,8 +446,8 @@ class GetBuildListResponse(BaseModel):
 
 
 class BuildStats(BaseModel):
-    duration_millis: Annotated[float, Field(alias='durationMillis', examples=[1000])]
-    run_time_secs: Annotated[float, Field(alias='runTimeSecs', examples=[45.718])]
+    duration_millis: Annotated[float | None, Field(alias='durationMillis', examples=[1000])] = None
+    run_time_secs: Annotated[float | None, Field(alias='runTimeSecs', examples=[45.718])] = None
     compute_units: Annotated[float, Field(alias='computeUnits', examples=[0.0126994444444444])]
 
 

src/apify_client/_resource_clients/actor.py

@@ -73,7 +73,7 @@ def get_actor_representation(
     actor_permission_level: ActorPermissionLevel | None = None,
 ) -> dict:
     """Get dictionary representation of the Actor."""
-    return {
+    actor_dict = {
         'name': name,
         'title': title,
         'description': description,
@@ -92,10 +92,6 @@ def get_actor_representation(
             'restartOnError': restart_on_error,
             'forcePermissionLevel': default_run_force_permission_level,
         },
-        'exampleRunInput': {
-            'body': example_run_input_body,
-            'contentType': example_run_input_content_type,
-        },
         'actorStandby': {
             'isEnabled': actor_standby_is_enabled,
             'desiredRequestsPerActorRun': actor_standby_desired_requests_per_actor_run,
@@ -108,6 +104,15 @@ def get_actor_representation(
         'actorPermissionLevel': actor_permission_level,
     }
 
+    # Only include exampleRunInput if at least one field is provided
+    if example_run_input_body is not None or example_run_input_content_type is not None:
+        actor_dict['exampleRunInput'] = {
+            'body': example_run_input_body,
+            'contentType': example_run_input_content_type,
+        }
+
+    return actor_dict
+
 
 class ActorClient(ResourceClient):
     """Sub-client for manipulating a single Actor."""

src/apify_client/_resource_clients/actor_collection.py

@@ -2,7 +2,7 @@
 
 from typing import TYPE_CHECKING, Any, Literal
 
-from apify_client._models import Actor, ActorShort
+from apify_client._models import Actor, ActorShort, CreateActorResponse
 from apify_client._resource_clients.actor import get_actor_representation
 from apify_client._resource_clients.base import ResourceCollectionClient, ResourceCollectionClientAsync
 from apify_client._utils import filter_out_none_values_recursively
@@ -133,8 +133,8 @@ def create(
             actor_standby_memory_mbytes=actor_standby_memory_mbytes,
         )
 
-        result = self._create(filter_out_none_values_recursively(actor_representation))
-        return Actor.model_validate(result)
+        result = self._create(filter_out_none_values_recursively(actor_representation, remove_empty_dicts=True))
+        return CreateActorResponse.model_validate(result).data
 
 
 class ActorCollectionClientAsync(ResourceCollectionClientAsync):
@@ -259,5 +259,5 @@ async def create(
             actor_standby_memory_mbytes=actor_standby_memory_mbytes,
         )
 
-        result = await self._create(filter_out_none_values_recursively(actor_representation))
-        return Actor.model_validate(result)
+        result = await self._create(filter_out_none_values_recursively(actor_representation, remove_empty_dicts=True))
+        return CreateActorResponse.model_validate(result).data

src/apify_client/_resource_clients/run.py

@@ -52,7 +52,11 @@ def get(self) -> Run | None:
             The retrieved Actor run data.
         """
         result = self._get()
-        return RunResponse.model_validate(result).data if result is not None else None
+
+        if result is None:
+            return None
+
+        return RunResponse.model_validate(result).data
 
     def update(
         self,
@@ -290,9 +294,9 @@ def get_streamed_log(self, to_logger: logging.Logger | None = None, *, from_star
         run_data = self.get()
         run_id = f'runId:{run_data.id}' if run_data and run_data.id else ''
 
-        actor_id = run_data.act_id if run_data and run_data.act_id else ''
+        actor_id = run_data.act_id if run_data else ''
         actor_data = self.root_client.actor(actor_id=actor_id).get() if actor_id else None
-        actor_name = actor_data.name if actor_data and hasattr(actor_data, 'name') and actor_data.name else ''
+        actor_name = actor_data.name if actor_data else ''
 
         if not to_logger:
             name = ' '.join(part for part in (actor_name, run_id) if part)
@@ -354,9 +358,9 @@ def get_status_message_watcher(
         run_data = self.get()
         run_id = f'runId:{run_data.id}' if run_data and run_data.id else ''
 
-        actor_id = run_data.act_id if run_data and run_data.act_id else ''
+        actor_id = run_data.act_id if run_data else ''
         actor_data = self.root_client.actor(actor_id=actor_id).get() if actor_id else None
-        actor_name = actor_data.name if actor_data and hasattr(actor_data, 'name') and actor_data.name else ''
+        actor_name = actor_data.name if actor_data else ''
 
         if not to_logger:
             name = ' '.join(part for part in (actor_name, run_id) if part)
@@ -624,9 +628,9 @@ async def get_streamed_log(
         run_data = await self.get()
         run_id = f'runId:{run_data.id}' if run_data and run_data.id else ''
 
-        actor_id = run_data.act_id if run_data and run_data.act_id else ''
+        actor_id = run_data.act_id if run_data else ''
         actor_data = await self.root_client.actor(actor_id=actor_id).get() if actor_id else None
-        actor_name = actor_data.name if actor_data and hasattr(actor_data, 'name') and actor_data.name else ''
+        actor_name = actor_data.name if actor_data else ''
 
         if not to_logger:
             name = ' '.join(part for part in (actor_name, run_id) if part)
@@ -687,10 +691,11 @@ async def get_status_message_watcher(
             `StatusMessageWatcher` instance.
         """
         run_data = await self.get()
-        run_id = f'runId:{run_data.id}' if run_data else ''
+
+        run_id = f'runId:{run_data.id}' if run_data and run_data.id else ''
 
         actor_id = run_data.act_id if run_data else ''
-        actor_data = await self.root_client.actor(actor_id=actor_id).get()
+        actor_data = await self.root_client.actor(actor_id=actor_id).get() if actor_id else None
         actor_name = actor_data.name if actor_data else ''
 
         if not to_logger: