fix: adapt Actor.start/call/call_task to apify-client v3 run_timeout and tolerate platform pricing-info env var omissions

apify-client v3 split the single `timeout` kwarg on `actor.start/call` and
`task.call` into `run_timeout` (server-side Actor-run timeout) and `timeout`
(HTTP request timeout). The SDK kept passing the inherited remaining-time to
`timeout=`, so the new run received the default platform timeout, breaking
the `inherit` timeout propagation.

The v3 pricing models also require `apifyMarginPercentage`, `createdAt`,
`startedAt`, and per-event `eventDescription`, but the platform's
`APIFY_ACTOR_PRICING_INFO` env var does not include them, so Configuration()
raised ValidationError on Actor startup. Inject safe defaults in a
BeforeValidator so validation succeeds on the Actor side.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: vdusek

src/apify/_actor.py

@@ -927,7 +927,7 @@ async def start(
             content_type=content_type,
             build=build,
             memory_mbytes=memory_mbytes,
-            timeout=actor_start_timeout if actor_start_timeout is not None else 'medium',
+            run_timeout=actor_start_timeout,
             wait_for_finish=wait_for_finish,
             webhooks=serialized_webhooks,
         )
@@ -1050,7 +1050,7 @@ async def call(
             content_type=content_type,
             build=build,
             memory_mbytes=memory_mbytes,
-            timeout=actor_call_timeout if actor_call_timeout is not None else 'no_timeout',
+            run_timeout=actor_call_timeout,
             webhooks=serialized_webhooks,
             wait_duration=wait,
             logger=logger,
@@ -1125,7 +1125,7 @@ async def call_task(
             task_input=task_input,
             build=build,
             memory_mbytes=memory_mbytes,
-            timeout=task_call_timeout if task_call_timeout is not None else 'no_timeout',
+            run_timeout=task_call_timeout,
             webhooks=serialized_webhooks,
             wait_duration=wait,
         )

src/apify/_configuration.py

@@ -71,6 +71,34 @@ def _load_storage_keys(data: None | str | ActorStorages) -> ActorStorages | None
     }
 
 
+def _normalize_actor_pricing_info(data: Any) -> Any:
+    """Parse and normalize the `APIFY_ACTOR_PRICING_INFO` env var for the apify-client pricing models.
+
+    The platform-provided env var omits some fields that are required by the apify-client pydantic models
+    (`apifyMarginPercentage`, `createdAt`, `startedAt`, and per-event `eventDescription`). Inject safe
+    defaults for those so validation succeeds on the Actor side.
+    """
+    if data is None or data == '':
+        return None
+    pricing_info = json.loads(data) if isinstance(data, str) else data
+    if not isinstance(pricing_info, dict):
+        return pricing_info
+
+    pricing_info.setdefault('apifyMarginPercentage', 0.0)
+    pricing_info.setdefault('createdAt', '1970-01-01T00:00:00.000Z')
+    pricing_info.setdefault('startedAt', '1970-01-01T00:00:00.000Z')
+
+    pricing_per_event = pricing_info.get('pricingPerEvent')
+    if isinstance(pricing_per_event, dict):
+        actor_charge_events = pricing_per_event.get('actorChargeEvents')
+        if isinstance(actor_charge_events, dict):
+            for event in actor_charge_events.values():
+                if isinstance(event, dict):
+                    event.setdefault('eventDescription', '')
+
+    return pricing_info
+
+
 @docs_group('Configuration')
 class Configuration(CrawleeConfiguration):
     """A class for specifying the configuration of an Actor.
@@ -471,7 +499,7 @@ class Configuration(CrawleeConfiguration):
             description='JSON string with prising info of the actor',
             discriminator='pricing_model',
         ),
-        BeforeValidator(lambda data: json.loads(data) if isinstance(data, str) else data or None),
+        BeforeValidator(_normalize_actor_pricing_info),
     ] = None
 
     charged_event_counts: Annotated[

tests/unit/actor/test_actor_helpers.py

@@ -268,7 +268,7 @@ async def test_remote_method_with_timedelta_timeout(
     calls = apify_client_async_patcher.calls[client_resource][client_method]
     assert len(calls) == 1
     _, kwargs = calls[0][0], calls[0][1]
-    assert kwargs.get('timeout') == timedelta(seconds=120)
+    assert kwargs.get('run_timeout') == timedelta(seconds=120)
 
 
 async def test_call_actor_with_remaining_time_deprecation(

tests/unit/actor/test_configuration.py

@@ -340,6 +340,28 @@ def test_actor_pricing_info_from_json_env_var(monkeypatch: pytest.MonkeyPatch) -
     assert config.actor_pricing_info.pricing_model == 'PAY_PER_EVENT'
 
 
+def test_actor_pricing_info_env_var_tolerates_platform_omissions(monkeypatch: pytest.MonkeyPatch) -> None:
+    """The platform env var may omit fields that apify-client models require; they should be injected with defaults."""
+
+    pricing_json = json.dumps(
+        {
+            'pricingModel': 'PAY_PER_EVENT',
+            'pricingPerEvent': {
+                'actorChargeEvents': {
+                    'search': {
+                        'eventPriceUsd': '0.01',
+                        'eventTitle': 'Search event',
+                    }
+                }
+            },
+        }
+    )
+    monkeypatch.setenv('APIFY_ACTOR_PRICING_INFO', pricing_json)
+    config = ApifyConfiguration()
+    assert config.actor_pricing_info is not None
+    assert config.actor_pricing_info.pricing_model == 'PAY_PER_EVENT'
+
+
 def test_actor_storage_json_env_var(monkeypatch: pytest.MonkeyPatch) -> None:
     """Test that actor_storages_json is parsed from JSON env var."""
     datasets = {'default': 'default_dataset_id', 'custom': 'custom_dataset_id'}