diff --git a/airflow/executors/base_executor.py b/airflow/executors/base_executor.py index 16f6fe9eb0f5a..fc753055194ea 100644 --- a/airflow/executors/base_executor.py +++ b/airflow/executors/base_executor.py @@ -64,6 +64,9 @@ def __init__(self, parallelism: int = PARALLELISM): self.running: Set[TaskInstanceKey] = set() self.event_buffer: Dict[TaskInstanceKey, EventBufferValueType] = {} + def __repr__(self): + return f"{self.__class__.__name__}(parallelism={self.parallelism})" + def start(self): # pragma: no cover """Executors may need to get things started."""