client.swarm.swarm_task
=======================

.. py:module:: client.swarm.swarm_task

.. autoapi-nested-parse::

   Swarm side task object.



Attributes
----------

.. autoapisummary::

   client.swarm.swarm_task.logger


Classes
-------

.. autoapisummary::

   client.swarm.swarm_task.SwarmTask


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

.. py:data:: logger

.. py:class:: SwarmTask(task_id: int, array_id: int, status: str, max_attempts: int, task_resources: jobmon.client.task_resources.TaskResources, cluster: jobmon.core.cluster.Cluster, resource_scales: Optional[Dict] = None, fallback_queues: Optional[List[jobmon.core.cluster_protocol.ClusterQueue]] = None, compute_resources_callable: Optional[Callable] = None)

   Bases: :py:obj:`object`


   Swarm side task object.


   .. py:attribute:: task_id


   .. py:attribute:: array_id


   .. py:attribute:: status


   .. py:attribute:: downstream_swarm_tasks
      :type:  Set[SwarmTask]


   .. py:attribute:: current_task_resources


   .. py:attribute:: compute_resources_callable
      :value: None



   .. py:attribute:: fallback_queues
      :value: None



   .. py:attribute:: resource_scales
      :value: None



   .. py:attribute:: cluster


   .. py:attribute:: max_attempts


   .. py:attribute:: num_upstreams
      :type:  int
      :value: 0



   .. py:attribute:: num_upstreams_done
      :type:  int
      :value: 0



   .. py:property:: all_upstreams_done
      :type: bool


      Return a bool of if upstreams are done or not.


   .. py:property:: downstream_tasks
      :type: List[SwarmTask]


      Return list of downstream tasks.


   .. py:method:: __hash__() -> int

      Returns the ID of the task.



   .. py:method:: __eq__(other: object) -> bool

      Check if the hashes of two tasks are equivalent.



   .. py:method:: __lt__(other: SwarmTask) -> bool

      Check if one hash is less than the has of another Task.