soulfire.fleet.SoulFireFleetTaskGroup¶

class soulfire.fleet.SoulFireFleetTaskGroup[ResultT: google.protobuf.message.Message](members: collections.abc.Iterable[FleetTaskMember[ResultT]], start_failures: collections.abc.Iterable[FleetTaskStartFailure])[source]¶

members¶

start_failures¶

property size: int¶

events(*, after_revision: int | None = None, headers: Headers = None, timeout_ms: int | None = None, buffer_size: int = 64) → soulfire.streams.Stream[FleetTaskStreamEvent, soulfire.errors.SoulFireOperationError][source]¶

results(*, concurrency: int = 8, headers: Headers = None, timeout_ms: int | None = None) → effect_py.Effect[FleetTaskReport[ResultT], soulfire.errors.SoulFireOperationError][source]¶

require_results(*, concurrency: int = 8, headers: Headers = None, timeout_ms: int | None = None) → effect_py.Effect[tuple[ResultT, ...], soulfire.errors.SoulFireOperationError | FleetTaskGroupError[ResultT]][source]¶

cancel(reason: str = '', *, concurrency: int = 8, headers: Headers = None, timeout_ms: int | None = None) → effect_py.Effect[FleetOperationReport[soulfire.task_pb2.BotTask], soulfire.errors.SoulFireOperationError][source]¶