etha.comm.execution

Communication executor.

Attributes

logger

Functions

execute_bucket_pipeline(→ None)
execute_chunk_simple(→ None)	Execute chunks using polymorphic prepare/finalize and transfer functions.

Module Contents

etha.comm.execution.execute_bucket_pipeline(buckets: list[etha.comm.ir.Bucket], max_in_flight: int = 2) → None

etha.comm.execution.execute_chunk_simple(chunks: list[etha.comm.ir.Chunk]) → None

Execute chunks using polymorphic prepare/finalize and transfer functions.

This is the simple sequential execution strategy - each chunk is fully prepared, launched, and finalized before moving to the next chunk.

etha.comm.execution.logger