def end(self):  # pragma: no cover
        raise NotImplementedError()
This method is called when the caller is done submitting job and is
dataset/ETHPy150Open airbnb/airflow/airflow/executors/base_executor.py/BaseExecutor.end