apify-sdk-python/tests/e2e/test_actor_call_timeouts.py at 994e97059eb997bf7ff1b39faf6aa2f1183f3534 · apify/apify-sdk-python · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
from __future__ import annotations

import asyncio
from typing import TYPE_CHECKING

from apify import Actor

if TYPE_CHECKING:
    from .conftest import MakeActorFunction, RunActorFunction


async def test_actor_start_inherit_timeout(
    make_actor: MakeActorFunction,
    run_actor: RunActorFunction,
) -> None:
    """Test that correct timeout is set when using `inherit` value for the `timeout` argument.

    In this test, one Actor starts itself again and checks that the timeout is correctly set on the second Actor run.
    Timeout should be the remaining time of the first Actor run calculated at the moment of the other Actor start."""

    async def main() -> None:
        from datetime import datetime, timezone

        async with Actor:
            actor_input = (await Actor.get_input()) or {}
            if actor_input.get('called_from_another_actor', False) is True:
                # If this Actor run was started with a specific argument (the second Actor run), return immediately.
                # Asserts checking the timeout are in the first Actor run.
                return

            # Start another run of this actor with timeout set to the time remaining in this actor run
            other_run_data = await Actor.call(
                actor_id=Actor.configuration.actor_id or '',
                run_input={'called_from_another_actor': True},
                timeout='inherit',
            )
            assert other_run_data is not None
            try:
                # To make sure that the actor is started
                await asyncio.sleep(5)
                assert other_run_data.options is not None
                assert Actor.configuration.timeout_at is not None
                assert Actor.configuration.started_at is not None

                remaining_time_after_actor_start = Actor.configuration.timeout_at - datetime.now(tz=timezone.utc)

                assert other_run_data.options.timeout > remaining_time_after_actor_start
                assert other_run_data.options.timeout < Actor.configuration.timeout_at - Actor.configuration.started_at
            finally:
                # Make sure the other actor run is aborted
                await Actor.apify_client.run(other_run_data.id).abort()

    actor = await make_actor(label='inherit-timeout', main_func=main)
    run_result = await run_actor(actor)

    assert run_result.status == 'SUCCEEDED'


async def test_actor_call_inherit_timeout(
    make_actor: MakeActorFunction,
    run_actor: RunActorFunction,
) -> None:
    """Test that correct timeout is set when using `inherit` value for the `timeout` argument.

    In this test, one Actor starts itself again and checks that the timeout is correctly set on the second Actor run.
    Timeout should be the remaining time of the first Actor run calculated at the moment of the other Actor call."""

    async def main() -> None:
        from datetime import datetime, timezone

        async with Actor:
            actor_input = (await Actor.get_input()) or {}
            if actor_input.get('called_from_another_actor', False) is True:
                # If this Actor run was started with a specific argument (the second Actor run), return immediately.
                # Asserts checking the timeout are in the first Actor run.
                return

            # Start another run of this actor with timeout set to the time remaining in this actor run
            other_run_data = await Actor.call(
                actor_id=Actor.configuration.actor_id or '',
                run_input={'called_from_another_actor': True},
                timeout='inherit',
            )

            assert other_run_data is not None
            try:
                # To make sure that the actor is started
                await asyncio.sleep(5)

                assert other_run_data.options is not None
                assert Actor.configuration.timeout_at is not None
                assert Actor.configuration.started_at is not None

                remaining_time_after_actor_start = Actor.configuration.timeout_at - datetime.now(tz=timezone.utc)

                assert other_run_data.options.timeout > remaining_time_after_actor_start
                assert other_run_data.options.timeout < Actor.configuration.timeout_at - Actor.configuration.started_at
            finally:
                # Make sure the other actor run is aborted
                await Actor.apify_client.run(other_run_data.id).abort()

    actor = await make_actor(label='remaining-timeout', main_func=main)
    run_result = await run_actor(actor)

    assert run_result.status == 'SUCCEEDED'