`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

Was this entry helpful?