summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAngelos Evripiotis <jevripiotis@bloomberg.net>2018-10-22 15:30:38 +0100
committerPhil Dawson <phildawson.0807@gmail.com>2018-10-23 08:37:47 +0000
commit898db5af11a60f6b6c1f70c6e9f3bdcb0f1adad4 (patch)
treec8f9e1a71c1046be4fa982b9d54af94cbaae8fa6
parentbe29e0f567e9633220228b7f3bc71ca34317d4ef (diff)
downloadbuildstream-aevri/rm-exitstack.tar.gz
plugins/sources: refactor, rm needless ExitStack-saevri/rm-exitstack
Remove two uses of ExitStack that aren't necessary and make the code a little harder to follow.
-rw-r--r--buildstream/plugins/sources/deb.py5
-rw-r--r--buildstream/plugins/sources/tar.py5
2 files changed, 4 insertions, 6 deletions
diff --git a/buildstream/plugins/sources/deb.py b/buildstream/plugins/sources/deb.py
index 7c70e1de9..e1d4b65d1 100644
--- a/buildstream/plugins/sources/deb.py
+++ b/buildstream/plugins/sources/deb.py
@@ -50,7 +50,7 @@ deb - stage files from .deb packages
"""
import tarfile
-from contextlib import contextmanager, ExitStack
+from contextlib import contextmanager
import arpy # pylint: disable=import-error
from .tar import TarSource
@@ -69,8 +69,7 @@ class DebSource(TarSource):
@contextmanager
def _get_tar(self):
- with ExitStack() as context:
- deb_file = context.enter_context(open(self._get_mirror_file(), 'rb'))
+ with open(self._get_mirror_file(), 'rb') as deb_file:
arpy_archive = arpy.Archive(fileobj=deb_file)
arpy_archive.read_all_headers()
data_tar_arpy = [v for k, v in arpy_archive.archived_files.items() if b"data.tar" in k][0]
diff --git a/buildstream/plugins/sources/tar.py b/buildstream/plugins/sources/tar.py
index 7814679c7..8bbc8fce5 100644
--- a/buildstream/plugins/sources/tar.py
+++ b/buildstream/plugins/sources/tar.py
@@ -57,7 +57,7 @@ tar - stage files from tar archives
import os
import tarfile
-from contextlib import contextmanager, ExitStack
+from contextlib import contextmanager
from tempfile import TemporaryFile
from buildstream import SourceError
@@ -88,8 +88,7 @@ class TarSource(DownloadableFileSource):
def _run_lzip(self):
assert self.host_lzip
with TemporaryFile() as lzip_stdout:
- with ExitStack() as context:
- lzip_file = context.enter_context(open(self._get_mirror_file(), 'r'))
+ with open(self._get_mirror_file(), 'r') as lzip_file:
self.call([self.host_lzip, '-d'],
stdin=lzip_file,
stdout=lzip_stdout)