diff --git a/airflow/providers/docker/operators/docker.py b/airflow/providers/docker/operators/docker.py index 7e0cd3ac49501..53dc5d92dea8d 100644 --- a/airflow/providers/docker/operators/docker.py +++ b/airflow/providers/docker/operators/docker.py @@ -406,6 +406,9 @@ def format_command(command: Union[str, List[str]]) -> Union[List[str], str]: def on_kill(self) -> None: if self.cli is not None: self.log.info('Stopping docker container') + if self.container is None: + self.log.info('Not attempting to kill container as it was not created') + return self.cli.stop(self.container['Id']) def __get_tls_config(self) -> Optional[tls.TLSConfig]: