INNER CODE UNIT · Python

drain_task

Hebbian-Robotics/hflow · src/hflow/app.py:546

            drain_task = asyncio.gather(*input_index_by_task, return_exceptions=True)
            while not drain_task.done():
                try:
                    await asyncio.shield(drain_task)
                except asyncio.CancelledError:
                    continue
    return [results_by_input_index[index] for index in range(len(inputs))]


@dataclass(frozen=True)
class _PreparedProcessConfiguration:
    """Run selections whose endpoint preflight has already succeeded."""

    enabled_stages: frozenset[Stage]
    registered_step_selection: RegisteredStepSelection


@dataclass(frozen=True)

View source record →