wait 10 minutes

Author: vdusek

tests/integration/conftest.py

@@ -244,7 +244,7 @@ async def _make_actor(
         print(f'Building Actor {actor_name}...')
         build_result = await actor_client.build(version_number='0.0')
         build_client = apify_client_async.build(build_result['id'])
-        build_client_result = await build_client.wait_for_finish(wait_secs=300)
+        build_client_result = await build_client.wait_for_finish(wait_secs=600)
 
         assert build_client_result is not None
         assert build_client_result['status'] == ActorJobStatus.SUCCEEDED

tests/integration/test_actor_api_helpers.py

@@ -29,7 +29,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -61,7 +61,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -91,7 +91,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -116,7 +116,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -127,7 +127,7 @@ async def main() -> None:
     assert call_result_2 is not None
 
     run_client_2 = apify_client_async.run(call_result_2['id'])
-    run_result_2 = await run_client_2.wait_for_finish(wait_secs=300)
+    run_result_2 = await run_client_2.wait_for_finish(wait_secs=600)
 
     assert run_result_2 is not None
     assert run_result_2['status'] == 'SUCCEEDED'
@@ -170,12 +170,12 @@ async def main_outer() -> None:
     assert outer_call_result is not None
 
     run_client_outer = apify_client_async.run(outer_call_result['id'])
-    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=300)
+    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=600)
 
     assert run_result_outer is not None
     assert run_result_outer['status'] == 'SUCCEEDED'
 
-    await inner_actor.last_run().wait_for_finish(wait_secs=300)
+    await inner_actor.last_run().wait_for_finish(wait_secs=600)
 
     inner_output_record = await inner_actor.last_run().key_value_store().get_record('OUTPUT')
     assert inner_output_record is not None
@@ -217,12 +217,12 @@ async def main_outer() -> None:
     assert outer_call_result is not None
 
     run_client_outer = apify_client_async.run(outer_call_result['id'])
-    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=300)
+    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=600)
 
     assert run_result_outer is not None
     assert run_result_outer['status'] == 'SUCCEEDED'
 
-    await inner_actor.last_run().wait_for_finish(wait_secs=300)
+    await inner_actor.last_run().wait_for_finish(wait_secs=600)
 
     inner_output_record = await inner_actor.last_run().key_value_store().get_record('OUTPUT')
     assert inner_output_record is not None
@@ -269,12 +269,12 @@ async def main_outer() -> None:
     assert outer_call_result is not None
 
     run_client_outer = apify_client_async.run(outer_call_result['id'])
-    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=300)
+    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=600)
 
     assert run_result_outer is not None
     assert run_result_outer['status'] == 'SUCCEEDED'
 
-    await inner_actor.last_run().wait_for_finish(wait_secs=300)
+    await inner_actor.last_run().wait_for_finish(wait_secs=600)
 
     inner_output_record = await inner_actor.last_run().key_value_store().get_record('OUTPUT')
     assert inner_output_record is not None
@@ -311,12 +311,12 @@ async def main_outer() -> None:
     assert outer_call_result is not None
 
     run_client_outer = apify_client_async.run(outer_call_result['id'])
-    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=300)
+    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=600)
 
     assert run_result_outer is not None
     assert run_result_outer['status'] == 'SUCCEEDED'
 
-    await inner_actor.last_run().wait_for_finish(wait_secs=300)
+    await inner_actor.last_run().wait_for_finish(wait_secs=600)
     inner_actor_last_run = await inner_actor.last_run().get()
     assert inner_actor_last_run is not None
     assert inner_actor_last_run['status'] == 'ABORTED'
@@ -370,7 +370,7 @@ async def main_outer() -> None:
     assert outer_call_result is not None
 
     run_client_outer = apify_client_async.run(outer_call_result['id'])
-    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=300)
+    run_result_outer = await run_client_outer.wait_for_finish(wait_secs=600)
 
     assert run_result_outer is not None
     assert run_result_outer['status'] == 'SUCCEEDED'
@@ -410,7 +410,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -491,12 +491,12 @@ async def main_client() -> None:
     assert ac_call_result is not None
 
     ac_run_client = apify_client_async.run(ac_call_result['id'])
-    ac_run_result = await ac_run_client.wait_for_finish(wait_secs=300)
+    ac_run_result = await ac_run_client.wait_for_finish(wait_secs=600)
 
     assert ac_run_result is not None
     assert ac_run_result['status'] == 'SUCCEEDED'
 
-    sa_run_result = await server_actor.last_run().wait_for_finish(wait_secs=300)
+    sa_run_result = await server_actor.last_run().wait_for_finish(wait_secs=600)
 
     assert sa_run_result is not None
     assert sa_run_result['status'] == 'SUCCEEDED'

tests/integration/test_actor_create_proxy_configuration.py

@@ -35,7 +35,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -81,7 +81,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'

tests/integration/test_actor_dataset.py

@@ -32,7 +32,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -57,7 +57,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -82,7 +82,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -115,7 +115,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'

tests/integration/test_actor_events.py

@@ -63,7 +63,7 @@ async def log_event(data: Any) -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -113,7 +113,7 @@ def count_event(data):  # type: ignore # noqa: ANN202, ANN001
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'

tests/integration/test_actor_key_value_store.py

@@ -31,7 +31,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -64,7 +64,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -117,7 +117,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -137,7 +137,7 @@ async def main_set() -> None:
     assert call_result_set is not None
 
     run_client_set = apify_client_async.run(call_result_set['id'])
-    run_result_set = await run_client_set.wait_for_finish(wait_secs=300)
+    run_result_set = await run_client_set.wait_for_finish(wait_secs=600)
 
     assert run_result_set is not None
     assert run_result_set['status'] == 'SUCCEEDED'
@@ -168,7 +168,7 @@ async def main_get() -> None:
     assert call_result_get is not None
 
     run_client_get = apify_client_async.run(call_result_get['id'])
-    run_result_get = await run_client_get.wait_for_finish(wait_secs=300)
+    run_result_get = await run_client_get.wait_for_finish(wait_secs=600)
 
     assert run_result_get is not None
     assert run_result_get['status'] == 'SUCCEEDED'
@@ -223,7 +223,7 @@ async def main():
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -254,7 +254,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'

tests/integration/test_actor_lifecycle.py

@@ -43,7 +43,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -66,7 +66,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -88,7 +88,7 @@ async def main() -> None:
         assert call_result is not None
 
         run_client = apify_client_async.run(call_result['id'])
-        run_result = await run_client.wait_for_finish(wait_secs=300)
+        run_result = await run_client.wait_for_finish(wait_secs=600)
 
         assert run_result is not None
         assert run_result['exitCode'] == exit_code
@@ -110,7 +110,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['exitCode'] == 1
@@ -121,7 +121,7 @@ async def main() -> None:
         assert call_result is not None
 
         run_client = apify_client_async.run(call_result['id'])
-        run_result = await run_client.wait_for_finish(wait_secs=300)
+        run_result = await run_client.wait_for_finish(wait_secs=600)
 
         assert run_result is not None
         assert run_result['exitCode'] == exit_code
@@ -132,7 +132,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'FAILED'
@@ -153,7 +153,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['exitCode'] == 91

tests/integration/test_actor_log.py

@@ -48,7 +48,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'FAILED'

tests/integration/test_actor_request_queue.py

@@ -32,7 +32,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -65,7 +65,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'

tests/integration/test_fixtures.py

@@ -31,7 +31,7 @@ async def main() -> None:
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -60,7 +60,7 @@ async def main():
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'
@@ -99,7 +99,7 @@ async def main():
     assert call_result is not None
 
     run_client = apify_client_async.run(call_result['id'])
-    run_result = await run_client.wait_for_finish(wait_secs=300)
+    run_result = await run_client.wait_for_finish(wait_secs=600)
 
     assert run_result is not None
     assert run_result['status'] == 'SUCCEEDED'