etha.comm.execution
===================

.. py:module:: etha.comm.execution

.. autoapi-nested-parse::

   Communication executor.



Attributes
----------

.. autoapisummary::

   etha.comm.execution.logger


Functions
---------

.. autoapisummary::

   etha.comm.execution.execute_bucket_pipeline
   etha.comm.execution.execute_chunk_simple


Module Contents
---------------

.. py:function:: execute_bucket_pipeline(buckets: list[etha.comm.ir.Bucket], max_in_flight: int = 2) -> None

.. py:function:: 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.


.. py:data:: logger