Removes container.
(container)
| 629 | |
| 630 | @staticmethod |
| 631 | def _rm_container(container): |
| 632 | """Removes container.""" |
| 633 | # We can have multiple threads trying to call "docker rm" on a container. |
| 634 | # Docker will fail one of those with "already running", but we actually |
| 635 | # want to block until it's removed. Using a lock to serialize the "docker # rm" |
| 636 | # calls handles that. |
| 637 | with container.lock: |
| 638 | if not container.removed: |
| 639 | _call(["docker", "rm", container.id], check=False) |
| 640 | container.removed = True |
| 641 | |
| 642 | def _create_build_image(self): |
| 643 | """Creates the "build image", with Impala compiled and data loaded.""" |
no test coverage detected