:py:mod:`aces.operations.flows`
===============================

.. py:module:: aces.operations.flows

.. autoapi-nested-parse::

   This contains prefect based workflows that may be called and used in other larger workflows. Specifically
   these particular flows are related to the tasks involing file interaction and similar oepraitons



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


Functions
~~~~~~~~~

.. autoapisummary::

   aces.operations.flows.flow_find_copy_measurement_sets



Attributes
~~~~~~~~~~

.. autoapisummary::

   aces.operations.flows.logger


.. py:data:: logger

   

.. py:function:: flow_find_copy_measurement_sets(src_dir: pathlib.Path, output_dir: pathlib.Path, expected_no: Optional[int] = None, overwrite: bool = False) -> Collection[pathlib.Path]

   Given a target directory to search and a SBID, search for MSs to copy and copy.

   Since this uses a prefect Task and its map method, there is no non-flow alternative. 

   Args:
       src_dir (Path): Directory thought to contain the SBID MSs
       output_dir (Path): Where to copy the MSs to. If directory does not exist an error is raised. 
       expected_no (Optional[int], optional): Number of MSs that should be found. Defaults to None.
       overwrite (bool, optional): If True and a MS that will be copied is found to exist, it is overwriten. Defaults to False.

   Returns:
       Collection[Path]: Paths of MSs that are copied