Update test to included statistics before reboot.

Temporarily point to unmerged crawlee version that contains the fix.

Author: Pijukatel

pyproject.toml

@@ -36,7 +36,7 @@ keywords = [
 dependencies = [
     "apify-client>=2.0.0,<3.0.0",
     "apify-shared>=2.0.0,<3.0.0",
-    "crawlee>=1.0.2,<2.0.0",
+    "crawlee @ git+https://github.com/apify/crawlee-python@crawler-persistance",
     "cachetools>=5.5.0",
     "cryptography>=42.0.0",
     "impit>=0.6.1",

tests/integration/actor_source_base/requirements.txt

@@ -1,4 +1,4 @@
 # The test fixture will put the Apify SDK wheel path on the next line
 APIFY_SDK_WHEEL_PLACEHOLDER
 uvicorn[standard]
-crawlee[parsel]>=1.0.0,<2.0.0
+crawlee[parsel] @ git+https://github.com/apify/crawlee-python@crawler-persistance

tests/integration/test_actor_lifecycle.py

@@ -122,7 +122,8 @@ async def main() -> None:
 async def test_actor_with_crawler_reboot(make_actor: MakeActorFunction, run_actor: RunActorFunction) -> None:
     """Test that crawler in actor works as expected after reboot.
 
-    Handle two requests. Reboot in between the two requests."""
+    Handle two requests. Reboot in between the two requests. The second run should include statistics of the fist run.
+    """
 
     async def main() -> None:
         from crawlee._types import BasicCrawlingContext, ConcurrencySettings
@@ -152,7 +153,8 @@ async def default_handler(context: BasicCrawlingContext) -> None:
             await crawler.run(requests)
 
             # Each time one request is finished.
-            assert crawler.statistics.state.requests_finished == 1
+            expected_requests_finished = 1 if first_run else 2
+            assert crawler.statistics.state.requests_finished == expected_requests_finished
 
     actor = await make_actor(label='migration', main_func=main)
     run_result = await run_actor(actor)