pipeline.src.shared_tasks.control_flow
======================================

.. py:module:: pipeline.src.shared_tasks.control_flow


Functions
---------

.. autoapisummary::

   pipeline.src.shared_tasks.control_flow.str_to_path
   pipeline.src.shared_tasks.control_flow.filter_results
   pipeline.src.shared_tasks.control_flow.flatten


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

.. py:function:: str_to_path(path: str) -> pathlib.Path

   Returns `Path` object corresponding to input `str`

   :param path: 'stairway/to/heaven'
   :type path: str

   :returns: Path('stairway/to/heaven')
   :rtype: Path


.. py:function:: filter_results(task_results) -> List

   Filters invalid results from an input mapped results list.

   :param task_results: List of (mapped) task results.

   :raises AssertionError: If input is not a list.

   :returns: Filtered list with SKIPs, Nones and Errors removed
   :rtype: List


.. py:function:: flatten(task_results: List[list]) -> list