feat: add restart_on_error option to actor start and call and to task in general

Author: DaveHanns

src/apify_client/clients/resource_clients/actor.py

@@ -153,7 +153,7 @@ def update(
             seo_title: The title of the Actor optimized for search engines.
             seo_description: The description of the Actor optimized for search engines.
             versions: The list of Actor versions.
-            restart_on_error: If true, the main Actor run process will be restarted whenever it exits with
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
                 a non-zero status code.
             is_public: Whether the Actor is public.
             is_deprecated: Whether the Actor is deprecated.
@@ -224,6 +224,7 @@ def start(
         build: str | None = None,
         max_items: int | None = None,
         max_total_charge_usd: Decimal | None = None,
+        restart_on_error: bool | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
         force_permission_level: ActorPermissionLevel | None = None,
@@ -242,6 +243,8 @@ def start(
             max_items: Maximum number of results that will be returned by this run. If the Actor is charged
                 per result, you will not be charged for more results than the given limit.
             max_total_charge_usd: A limit on the total charged amount for pay-per-event actors.
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
+                a non-zero status code.
             memory_mbytes: Memory limit for the run, in megabytes. By default, the run uses a memory limit
                 specified in the default run configuration for the Actor.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
@@ -267,6 +270,7 @@ def start(
             build=build,
             maxItems=max_items,
             maxTotalChargeUsd=max_total_charge_usd,
+            restartOnError=restart_on_error,
             memory=memory_mbytes,
             timeout=timeout_secs,
             waitForFinish=wait_for_finish,
@@ -292,6 +296,7 @@ def call(
         build: str | None = None,
         max_items: int | None = None,
         max_total_charge_usd: Decimal | None = None,
+        restart_on_error: bool | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
         webhooks: list[dict] | None = None,
@@ -313,6 +318,8 @@ def call(
             max_items: Maximum number of results that will be returned by this run. If the Actor is charged
                 per result, you will not be charged for more results than the given limit.
             max_total_charge_usd: A limit on the total charged amount for pay-per-event actors.
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
+                a non-zero status code.
             memory_mbytes: Memory limit for the run, in megabytes. By default, the run uses a memory limit
                 specified in the default run configuration for the Actor.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
@@ -338,6 +345,7 @@ def call(
             build=build,
             max_items=max_items,
             max_total_charge_usd=max_total_charge_usd,
+            restart_on_error=restart_on_error,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
             webhooks=webhooks,
@@ -565,7 +573,7 @@ async def update(
             seo_title: The title of the Actor optimized for search engines.
             seo_description: The description of the Actor optimized for search engines.
             versions: The list of Actor versions.
-            restart_on_error: If true, the main Actor run process will be restarted whenever it exits with
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
                 a non-zero status code.
             is_public: Whether the Actor is public.
             is_deprecated: Whether the Actor is deprecated.
@@ -636,6 +644,7 @@ async def start(
         build: str | None = None,
         max_items: int | None = None,
         max_total_charge_usd: Decimal | None = None,
+        restart_on_error: bool | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
         force_permission_level: ActorPermissionLevel | None = None,
@@ -654,6 +663,8 @@ async def start(
             max_items: Maximum number of results that will be returned by this run. If the Actor is charged
                 per result, you will not be charged for more results than the given limit.
             max_total_charge_usd: A limit on the total charged amount for pay-per-event actors.
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
+                a non-zero status code.
             memory_mbytes: Memory limit for the run, in megabytes. By default, the run uses a memory limit
                 specified in the default run configuration for the Actor.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
@@ -679,6 +690,7 @@ async def start(
             build=build,
             maxItems=max_items,
             maxTotalChargeUsd=max_total_charge_usd,
+            restartOnError=restart_on_error,
             memory=memory_mbytes,
             timeout=timeout_secs,
             waitForFinish=wait_for_finish,
@@ -704,6 +716,7 @@ async def call(
         build: str | None = None,
         max_items: int | None = None,
         max_total_charge_usd: Decimal | None = None,
+        restart_on_error: bool | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
         webhooks: list[dict] | None = None,
@@ -725,6 +738,8 @@ async def call(
             max_items: Maximum number of results that will be returned by this run. If the Actor is charged
                 per result, you will not be charged for more results than the given limit.
             max_total_charge_usd: A limit on the total charged amount for pay-per-event actors.
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
+                a non-zero status code.
             memory_mbytes: Memory limit for the run, in megabytes. By default, the run uses a memory limit
                 specified in the default run configuration for the Actor.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
@@ -750,6 +765,7 @@ async def call(
             build=build,
             max_items=max_items,
             max_total_charge_usd=max_total_charge_usd,
+            restart_on_error=restart_on_error,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
             webhooks=webhooks,

src/apify_client/clients/resource_clients/actor_collection.py

@@ -80,7 +80,7 @@ def create(
             seo_title: The title of the Actor optimized for search engines.
             seo_description: The description of the Actor optimized for search engines.
             versions: The list of Actor versions.
-            restart_on_error: If true, the main Actor run process will be restarted whenever it exits with
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
                 a non-zero status code.
             is_public: Whether the Actor is public.
             is_deprecated: Whether the Actor is deprecated.
@@ -205,7 +205,7 @@ async def create(
             seo_title: The title of the Actor optimized for search engines.
             seo_description: The description of the Actor optimized for search engines.
             versions: The list of Actor versions.
-            restart_on_error: If true, the main Actor run process will be restarted whenever it exits with
+            restart_on_error: If true, the Actor run process will be restarted whenever it exits with
                 a non-zero status code.
             is_public: Whether the Actor is public.
             is_deprecated: Whether the Actor is deprecated.

src/apify_client/clients/resource_clients/task.py

@@ -32,6 +32,7 @@ def get_task_representation(
     max_items: int | None = None,
     memory_mbytes: int | None = None,
     timeout_secs: int | None = None,
+    restart_on_error: bool | None = None,
     title: str | None = None,
     actor_standby_desired_requests_per_actor_run: int | None = None,
     actor_standby_max_requests_per_actor_run: int | None = None,
@@ -48,6 +49,7 @@ def get_task_representation(
             'maxItems': max_items,
             'memoryMbytes': memory_mbytes,
             'timeoutSecs': timeout_secs,
+            'restartOnError': restart_on_error,
         },
         'input': task_input,
         'title': title,
@@ -87,6 +89,7 @@ def update(
         max_items: int | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
+        restart_on_error: bool | None = None,
         title: str | None = None,
         actor_standby_desired_requests_per_actor_run: int | None = None,
         actor_standby_max_requests_per_actor_run: int | None = None,
@@ -109,6 +112,8 @@ def update(
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
             task_input: Task input dictionary.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             title: A human-friendly equivalent of the name.
             actor_standby_desired_requests_per_actor_run: The desired number of concurrent HTTP requests for
                 a single Actor Standby run.
@@ -129,6 +134,7 @@ def update(
             max_items=max_items,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
+            restart_on_error=restart_on_error,
             title=title,
             actor_standby_desired_requests_per_actor_run=actor_standby_desired_requests_per_actor_run,
             actor_standby_max_requests_per_actor_run=actor_standby_max_requests_per_actor_run,
@@ -154,6 +160,7 @@ def start(
         max_items: int | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
+        restart_on_error: bool | None = None,
         wait_for_finish: int | None = None,
         webhooks: list[dict] | None = None,
     ) -> dict:
@@ -171,6 +178,8 @@ def start(
                 in the task settings.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             wait_for_finish: The maximum number of seconds the server waits for the run to finish. By default,
                 it is 0, the maximum value is 60.
             webhooks: Optional ad-hoc webhooks (https://docs.apify.com/webhooks/ad-hoc-webhooks) associated with
@@ -189,6 +198,7 @@ def start(
             maxItems=max_items,
             memory=memory_mbytes,
             timeout=timeout_secs,
+            restartOnError=restart_on_error,
             waitForFinish=wait_for_finish,
             webhooks=encode_webhook_list_to_base64(webhooks) if webhooks is not None else None,
         )
@@ -211,6 +221,7 @@ def call(
         max_items: int | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
+        restart_on_error: bool | None = None,
         webhooks: list[dict] | None = None,
         wait_secs: int | None = None,
     ) -> dict | None:
@@ -230,6 +241,8 @@ def call(
                 in the task settings.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             webhooks: Specifies optional webhooks associated with the Actor run, which can be used to receive
                 a notification e.g. when the Actor finished or failed. Note: if you already have a webhook set up for
                 the Actor or task, you do not have to add it again here.
@@ -245,6 +258,7 @@ def call(
             max_items=max_items,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
+            restart_on_error=restart_on_error,
             webhooks=webhooks,
         )
 
@@ -343,6 +357,7 @@ async def update(
         max_items: int | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
+        restart_on_error: bool | None = None,
         title: str | None = None,
         actor_standby_desired_requests_per_actor_run: int | None = None,
         actor_standby_max_requests_per_actor_run: int | None = None,
@@ -364,6 +379,8 @@ async def update(
                 in the task settings.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             task_input: Task input dictionary.
             title: A human-friendly equivalent of the name.
             actor_standby_desired_requests_per_actor_run: The desired number of concurrent HTTP requests for
@@ -385,6 +402,7 @@ async def update(
             max_items=max_items,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
+            restart_on_error=restart_on_error,
             title=title,
             actor_standby_desired_requests_per_actor_run=actor_standby_desired_requests_per_actor_run,
             actor_standby_max_requests_per_actor_run=actor_standby_max_requests_per_actor_run,
@@ -410,6 +428,7 @@ async def start(
         max_items: int | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
+        restart_on_error: bool | None = None,
         wait_for_finish: int | None = None,
         webhooks: list[dict] | None = None,
     ) -> dict:
@@ -427,6 +446,8 @@ async def start(
                 in the task settings.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             wait_for_finish: The maximum number of seconds the server waits for the run to finish. By default,
                 it is 0, the maximum value is 60.
             webhooks: Optional ad-hoc webhooks (https://docs.apify.com/webhooks/ad-hoc-webhooks) associated with
@@ -445,6 +466,7 @@ async def start(
             maxItems=max_items,
             memory=memory_mbytes,
             timeout=timeout_secs,
+            restartOnError=restart_on_error,
             waitForFinish=wait_for_finish,
             webhooks=encode_webhook_list_to_base64(webhooks) if webhooks is not None else None,
         )
@@ -467,6 +489,7 @@ async def call(
         max_items: int | None = None,
         memory_mbytes: int | None = None,
         timeout_secs: int | None = None,
+        restart_on_error: bool | None = None,
         webhooks: list[dict] | None = None,
         wait_secs: int | None = None,
     ) -> dict | None:
@@ -486,6 +509,8 @@ async def call(
                 in the task settings.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             webhooks: Specifies optional webhooks associated with the Actor run, which can be used to receive
                 a notification e.g. when the Actor finished or failed. Note: if you already have a webhook set up for
                 the Actor or task, you do not have to add it again here.
@@ -501,6 +526,7 @@ async def call(
             max_items=max_items,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
+            restart_on_error=restart_on_error,
             webhooks=webhooks,
         )
 

src/apify_client/clients/resource_clients/task_collection.py

@@ -47,6 +47,7 @@ def create(
         timeout_secs: int | None = None,
         memory_mbytes: int | None = None,
         max_items: int | None = None,
+        restart_on_error: bool | None = None,
         task_input: dict | None = None,
         title: str | None = None,
         actor_standby_desired_requests_per_actor_run: int | None = None,
@@ -70,6 +71,8 @@ def create(
                 is charged per result, you will not be charged for more results than the given limit.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             task_input: Task input object.
             title: A human-friendly equivalent of the name.
             actor_standby_desired_requests_per_actor_run: The desired number of concurrent HTTP requests for
@@ -92,6 +95,7 @@ def create(
             max_items=max_items,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
+            restart_on_error=restart_on_error,
             title=title,
             actor_standby_desired_requests_per_actor_run=actor_standby_desired_requests_per_actor_run,
             actor_standby_max_requests_per_actor_run=actor_standby_max_requests_per_actor_run,
@@ -140,6 +144,7 @@ async def create(
         timeout_secs: int | None = None,
         memory_mbytes: int | None = None,
         max_items: int | None = None,
+        restart_on_error: bool | None = None,
         task_input: dict | None = None,
         title: str | None = None,
         actor_standby_desired_requests_per_actor_run: int | None = None,
@@ -163,6 +168,8 @@ async def create(
                 is charged per result, you will not be charged for more results than the given limit.
             timeout_secs: Optional timeout for the run, in seconds. By default, the run uses timeout specified
                 in the task settings.
+            restart_on_error: If true, the Task run process will be restarted whenever it exits with
+                a non-zero status code.
             task_input: Task input object.
             title: A human-friendly equivalent of the name.
             actor_standby_desired_requests_per_actor_run: The desired number of concurrent HTTP requests for
@@ -185,6 +192,7 @@ async def create(
             max_items=max_items,
             memory_mbytes=memory_mbytes,
             timeout_secs=timeout_secs,
+            restart_on_error=restart_on_error,
             title=title,
             actor_standby_desired_requests_per_actor_run=actor_standby_desired_requests_per_actor_run,
             actor_standby_max_requests_per_actor_run=actor_standby_max_requests_per_actor_run,