def __init__(self, parallelism=PARALLELISM):
        self.parallelism = parallelism
        self.queued_tasks = {}
        self.running = {}
        self.event_buffer = {}
Class to derive in order to interface with executor-type systems
dataset/ETHPy150Open airbnb/airflow/airflow/executors/base_executor.py/BaseExecutor.__init__