feat: list task child runs in Actor.child_runs()

Author: vdusek

src/apify/_actor.py

@@ -1233,9 +1233,9 @@ async def _wait_for_child_run(
     async def child_runs(self) -> dict[str, ChildRunInfo]:
         """Get the named child runs of this Actor run, with their current state.
 
-        Every run started by `Actor.start` or `Actor.call` with a `name` is included, even one started before a
-        migration or resurrection of this Actor run. Runs started without a `name` are not tracked. Each run is fetched
-        from the API when this method is called, so the result is a snapshot.
+        Every run started by `Actor.start`, `Actor.call` or `Actor.call_task` with a `run_name` is included, even one
+        started before a migration or resurrection of this Actor run. Runs started without a `run_name` are not
+        tracked. Each run is fetched from the API when this method is called, so the result is a snapshot.
 
         Returns:
             The child runs by name.

src/apify/_child_runs.py

@@ -64,8 +64,11 @@ def _describe_started_from(actor_id: str | None, task_id: str | None) -> str:
 class ChildRunInfo:
     """A named child run of this Actor run, as returned by `Actor.child_runs`."""
 
-    actor_id: str
-    """The Actor ID or name the child was started with, as the caller passed it."""
+    actor_id: str | None
+    """The Actor ID or name the child was started with, as the caller passed it, or `None` for a task run."""
+
+    task_id: str | None
+    """The task ID or name the child was started with, as the caller passed it, or `None` for an Actor run."""
 
     run_id: str
     """ID of the current run under this name."""
@@ -170,6 +173,7 @@ async def list_runs(self, client: ApifyClientAsync) -> dict[str, ChildRunInfo]:
         return {
             name: ChildRunInfo(
                 actor_id=record.actor_id,
+                task_id=record.task_id,
                 run_id=record.run_id,
                 run=run,
                 previous_run_ids=list(record.previous_run_ids),

tests/unit/actor/test_actor_child_runs.py

@@ -457,17 +457,19 @@ async def get_run(run_client: Any, *_args: Any, **_kwargs: Any) -> Run | None:
             CHILD_RUNS_KEY,
             {
                 'scrape-eu': {'actorId': 'some-actor', 'runId': 'eu-run', 'previousRunIds': ['failed-run']},
-                'scrape-us': {'actorId': 'other-actor', 'runId': 'us-run', 'previousRunIds': []},
+                'scrape-us': {'taskId': 'some-task', 'runId': 'us-run', 'previousRunIds': []},
             },
         )
         child_runs = await Actor.child_runs()
 
     assert child_runs.keys() == {'scrape-eu', 'scrape-us'}
     assert child_runs['scrape-eu'].actor_id == 'some-actor'
+    assert child_runs['scrape-eu'].task_id is None
     assert child_runs['scrape-eu'].run_id == 'eu-run'
     assert child_runs['scrape-eu'].run == runs['eu-run']
     assert child_runs['scrape-eu'].previous_run_ids == ['failed-run']
-    assert child_runs['scrape-us'].actor_id == 'other-actor'
+    assert child_runs['scrape-us'].actor_id is None
+    assert child_runs['scrape-us'].task_id == 'some-task'
     assert child_runs['scrape-us'].run is None
 
 
@@ -479,7 +481,7 @@ async def test_child_runs_includes_run_started_in_this_attempt(
     apify_client_async_patcher.patch('run', 'get', return_value=make_run('new-run', 'RUNNING'))
 
     async with Actor:
-        await Actor.start('some-actor', name='scrape-eu')
+        await Actor.start('some-actor', run_name='scrape-eu')
         child_runs = await Actor.child_runs()
 
     assert child_runs['scrape-eu'].run_id == 'new-run'