oaebu_workflows.airflow_pools

Module Contents

Classes

AirflowPool	Constructor an AirflowPool instance
CrossrefEventsPool	Constructor CrossrefEventsPool instance

class oaebu_workflows.airflow_pools.AirflowPool(pool_name, pool_slots, pool_description)

Constructor an AirflowPool instance

Parameters:

• pool_name (str) – The name of this pool

• pool_slots (int) – The number of slots assigned to this pool

• pool_description (str) – A description of this pool

get_pool()

create_pool()

create_or_get_pool()

class oaebu_workflows.airflow_pools.CrossrefEventsPool(pool_slots=15)

Bases: AirflowPool

Constructor CrossrefEventsPool instance

Parameters:

pool_slots (int) – The number of slots assigned to this pool