airflow.models.pool

Module Contents

class airflow.models.pool.Pool[source]

Bases: airflow.models.base.Base

__tablename__ = slot_pool[source]
id[source]
pool[source]
slots[source]
description[source]
DEFAULT_POOL_NAME = default_pool[source]
__repr__(self)[source]
static get_pool(pool_name, session=None)[source]
static get_default_pool(session=None)[source]
to_json(self)[source]
occupied_slots(self, session)[source]

Returns the number of slots used by running/queued tasks at the moment.

used_slots(self, session)[source]

Returns the number of slots used by running tasks at the moment.

queued_slots(self, session)[source]

Returns the number of slots used by queued tasks at the moment.

open_slots(self, session)[source]

Returns the number of slots open at the moment