cars.orchestrator.cluster.sequential_cluster
============================================

.. py:module:: cars.orchestrator.cluster.sequential_cluster

.. autoapi-nested-parse::

   Contains functions for sequential cluster



Classes
-------

.. autoapisummary::

   cars.orchestrator.cluster.sequential_cluster.SequentialCluster


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

.. py:class:: SequentialCluster(conf_cluster, out_dir, log_dir, launch_worker=True)

   Bases: :py:obj:`cars.orchestrator.cluster.abstract_cluster.AbstractCluster`


   SequentialCluster


   .. py:attribute:: profiling


   .. py:attribute:: out_dir


   .. py:attribute:: launch_worker
      :value: True



   .. py:method:: check_conf(conf)

      Check configuration

      :param conf: configuration to check
      :type conf: dict

      :return: overloaded configuration
      :rtype: dict




   .. py:method:: get_delayed_type()

      Get delayed type



   .. py:method:: cleanup(keep_shared_dir=False)

      Cleanup cluster




   .. py:method:: create_task_wrapped(func, nout=2)

      Create task

      :param func: function
      :param nout: number of outputs



   .. py:method:: start_tasks(task_list)

      Start all tasks

      :param task_list: task list



   .. py:method:: scatter(data, broadcast=True)

      Distribute data through workers

      :param data: task data



   .. py:method:: future_iterator(future_list, timeout=None)

      Start all tasks

      :param future_list: future_list list