Angelos Evripiotis pushed to branch aevri/tox_no_cov at BuildStream / buildstream
Commits:
-
c87bb592
by Jürg Billeter at 2019-01-10T09:43:37Z
-
26e33346
by Jürg Billeter at 2019-01-10T12:50:15Z
-
06deb4c4
by Jürg Billeter at 2019-01-10T12:50:15Z
-
0c2a66b3
by Jürg Billeter at 2019-01-10T13:06:02Z
-
f86bc760
by Jürg Billeter at 2019-01-10T13:34:56Z
-
347eb34e
by Angelos Evripiotis at 2019-01-10T14:38:23Z
-
6bc27bc1
by Angelos Evripiotis at 2019-01-10T15:07:46Z
-
0b83d024
by Tristan Van Berkom at 2019-01-10T20:02:50Z
-
630e26f1
by Tristan Van Berkom at 2019-01-10T20:03:52Z
-
d1d7de57
by Tristan Van Berkom at 2019-01-11T04:13:16Z
-
276b8d48
by Tristan Van Berkom at 2019-01-11T04:42:24Z
-
fc3dcec8
by Angelos Evripiotis at 2019-01-11T16:45:00Z
-
f86b7ff3
by Angelos Evripiotis at 2019-01-11T16:45:00Z
13 changed files:
- CONTRIBUTING.rst
- buildstream/_options/optionarch.py
- buildstream/_pipeline.py
- buildstream/_platform/platform.py
- buildstream/element.py
- requirements/dev-requirements.txt
- + tests/format/option-arch-alias/element.bst
- + tests/format/option-arch-alias/project.conf
- + tests/format/option-arch-unknown/element.bst
- + tests/format/option-arch-unknown/project.conf
- tests/format/optionarch.py
- + tests/frontend/order.py
- tests/testutils/runcli.py
Changes:
... | ... | @@ -553,7 +553,7 @@ One problem which arises from this is that we end up having symbols |
553 | 553 |
which are *public* according to the :ref:`rules discussed in the previous section
|
554 | 554 |
<contributing_public_and_private>`, but must be hidden away from the
|
555 | 555 |
*"Public API Surface"*. For example, BuildStream internal classes need
|
556 |
-to invoke methods on the ``Element`` and ``Source`` classes, wheras these
|
|
556 |
+to invoke methods on the ``Element`` and ``Source`` classes, whereas these
|
|
557 | 557 |
methods need to be hidden from the *"Public API Surface"*.
|
558 | 558 |
|
559 | 559 |
This is where BuildStream deviates from the PEP-8 standard for public
|
... | ... | @@ -631,7 +631,7 @@ An element plugin will derive from Element by importing:: |
631 | 631 |
|
632 | 632 |
from buildstream import Element
|
633 | 633 |
|
634 |
-When importing utilities specifically, dont import function names
|
|
634 |
+When importing utilities specifically, don't import function names
|
|
635 | 635 |
from there, instead import the module itself::
|
636 | 636 |
|
637 | 637 |
from . import utils
|
... | ... | @@ -737,7 +737,7 @@ Abstract methods |
737 | 737 |
~~~~~~~~~~~~~~~~
|
738 | 738 |
In BuildStream, an *"Abstract Method"* is a bit of a misnomer and does
|
739 | 739 |
not match up to how Python defines abstract methods, we need to seek out
|
740 |
-a new nomanclature to refer to these methods.
|
|
740 |
+a new nomenclature to refer to these methods.
|
|
741 | 741 |
|
742 | 742 |
In Python, an *"Abstract Method"* is a method which **must** be
|
743 | 743 |
implemented by a subclass, whereas all methods in Python can be
|
... | ... | @@ -960,7 +960,7 @@ possible, and avoid any cyclic relationships in modules. |
960 | 960 |
For instance, the ``Source`` objects are owned by ``Element``
|
961 | 961 |
objects in the BuildStream data model, and as such the ``Element``
|
962 | 962 |
will delegate some activities to the ``Source`` objects in its
|
963 |
-possesion. The ``Source`` objects should however never call functions
|
|
963 |
+possession. The ``Source`` objects should however never call functions
|
|
964 | 964 |
on the ``Element`` object, nor should the ``Source`` object itself
|
965 | 965 |
have any understanding of what an ``Element`` is.
|
966 | 966 |
|
... | ... | @@ -1223,7 +1223,7 @@ For further information about using the reStructuredText with sphinx, please see |
1223 | 1223 |
Building Docs
|
1224 | 1224 |
~~~~~~~~~~~~~
|
1225 | 1225 |
Before you can build the docs, you will end to ensure that you have installed
|
1226 |
-the required :ref:`buid dependencies <contributing_build_deps>` as mentioned
|
|
1226 |
+the required :ref:`build dependencies <contributing_build_deps>` as mentioned
|
|
1227 | 1227 |
in the testing section above.
|
1228 | 1228 |
|
1229 | 1229 |
To build the documentation, just run the following::
|
... | ... | @@ -1365,7 +1365,7 @@ Structure of an example |
1365 | 1365 |
'''''''''''''''''''''''
|
1366 | 1366 |
The :ref:`tutorial <tutorial>` and the :ref:`examples <examples>` sections
|
1367 | 1367 |
of the documentation contain a series of sample projects, each chapter in
|
1368 |
-the tutoral, or standalone example uses a sample project.
|
|
1368 |
+the tutorial, or standalone example uses a sample project.
|
|
1369 | 1369 |
|
1370 | 1370 |
Here is the the structure for adding new examples and tutorial chapters.
|
1371 | 1371 |
|
... | ... | @@ -1471,8 +1471,8 @@ Installing build dependencies |
1471 | 1471 |
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
1472 | 1472 |
Some of BuildStream's dependencies have non-python build dependencies. When
|
1473 | 1473 |
running tests with ``tox``, you will first need to install these dependencies.
|
1474 |
-Exact steps to install these will depend on your oprtation systemm. Commands
|
|
1475 |
-for installing them for some common distributions are lised below.
|
|
1474 |
+Exact steps to install these will depend on your operating system. Commands
|
|
1475 |
+for installing them for some common distributions are listed below.
|
|
1476 | 1476 |
|
1477 | 1477 |
For Fedora-based systems::
|
1478 | 1478 |
|
... | ... | @@ -1534,17 +1534,27 @@ You can always abort on the first failure by running:: |
1534 | 1534 |
|
1535 | 1535 |
tox -- -x
|
1536 | 1536 |
|
1537 |
+Similarly, you may also be interested in the ``--last-failed`` and
|
|
1538 |
+``--failed-first`` options as per the
|
|
1539 |
+`pytest cache <https://docs.pytest.org/en/latest/cache.html>`_ documentation.
|
|
1540 |
+ |
|
1537 | 1541 |
If you want to run a specific test or a group of tests, you
|
1538 | 1542 |
can specify a prefix to match. E.g. if you want to run all of
|
1539 | 1543 |
the frontend tests you can do::
|
1540 | 1544 |
|
1541 | 1545 |
tox -- tests/frontend/
|
1542 | 1546 |
|
1543 |
-Specific tests can be chosen by using the :: delimeter after the test module.
|
|
1547 |
+Specific tests can be chosen by using the :: delimiter after the test module.
|
|
1544 | 1548 |
If you wanted to run the test_build_track test within frontend/buildtrack.py you could do::
|
1545 | 1549 |
|
1546 | 1550 |
tox -- tests/frontend/buildtrack.py::test_build_track
|
1547 | 1551 |
|
1552 |
+When running only a few tests, you may find the coverage and timing output
|
|
1553 |
+excessive, there are options to trim them. Note that coverage step will fail.
|
|
1554 |
+Here is an example::
|
|
1555 |
+ |
|
1556 |
+ tox -- --no-cov --durations=1 tests/frontend/buildtrack.py::test_build_track
|
|
1557 |
+ |
|
1548 | 1558 |
We also have a set of slow integration tests that are disabled by
|
1549 | 1559 |
default - you will notice most of them marked with SKIP in the pytest
|
1550 | 1560 |
output. To run them, you can use::
|
... | ... | @@ -1560,7 +1570,7 @@ can run ``tox`` with ``-r`` or ``--recreate`` option. |
1560 | 1570 |
.. note::
|
1561 | 1571 |
|
1562 | 1572 |
By default, we do not allow use of site packages in our ``tox``
|
1563 |
- confguration to enable running the tests in an isolated environment.
|
|
1573 |
+ configuration to enable running the tests in an isolated environment.
|
|
1564 | 1574 |
If you need to enable use of site packages for whatever reason, you can
|
1565 | 1575 |
do so by passing the ``--sitepackages`` option to ``tox``. Also, you will
|
1566 | 1576 |
not need to install any of the build dependencies mentioned above if you
|
... | ... | @@ -1597,7 +1607,7 @@ under test before displaying the combined coverage. |
1597 | 1607 |
Adding tests
|
1598 | 1608 |
~~~~~~~~~~~~
|
1599 | 1609 |
Tests are found in the tests subdirectory, inside of which
|
1600 |
-there is a separarate directory for each *domain* of tests.
|
|
1610 |
+there is a separate directory for each *domain* of tests.
|
|
1601 | 1611 |
All tests are collected as::
|
1602 | 1612 |
|
1603 | 1613 |
tests/*/*.py
|
... | ... | @@ -17,6 +17,8 @@ |
17 | 17 |
# Authors:
|
18 | 18 |
# Tristan Van Berkom <tristan vanberkom codethink co uk>
|
19 | 19 |
|
20 |
+from .. import _yaml
|
|
21 |
+from .._exceptions import LoadError, LoadErrorReason, PlatformError
|
|
20 | 22 |
from .._platform import Platform
|
21 | 23 |
from .optionenum import OptionEnum
|
22 | 24 |
|
... | ... | @@ -41,7 +43,34 @@ class OptionArch(OptionEnum): |
41 | 43 |
super(OptionArch, self).load(node, allow_default_definition=False)
|
42 | 44 |
|
43 | 45 |
def load_default_value(self, node):
|
44 |
- return Platform.get_host_arch()
|
|
46 |
+ arch = Platform.get_host_arch()
|
|
47 |
+ |
|
48 |
+ default_value = None
|
|
49 |
+ |
|
50 |
+ for index, value in enumerate(self.values):
|
|
51 |
+ try:
|
|
52 |
+ canonical_value = Platform.canonicalize_arch(value)
|
|
53 |
+ if default_value is None and canonical_value == arch:
|
|
54 |
+ default_value = value
|
|
55 |
+ # Do not terminate the loop early to ensure we validate
|
|
56 |
+ # all values in the list.
|
|
57 |
+ except PlatformError as e:
|
|
58 |
+ provenance = _yaml.node_get_provenance(node, key='values', indices=[index])
|
|
59 |
+ prefix = ""
|
|
60 |
+ if provenance:
|
|
61 |
+ prefix = "{}: ".format(provenance)
|
|
62 |
+ raise LoadError(LoadErrorReason.INVALID_DATA,
|
|
63 |
+ "{}Invalid value for {} option '{}': {}"
|
|
64 |
+ .format(prefix, self.OPTION_TYPE, self.name, e))
|
|
65 |
+ |
|
66 |
+ if default_value is None:
|
|
67 |
+ # Host architecture is not supported by the project.
|
|
68 |
+ # Do not raise an error here as the user may override it.
|
|
69 |
+ # If the user does not override it, an error will be raised
|
|
70 |
+ # by resolve()/validate().
|
|
71 |
+ default_value = arch
|
|
72 |
+ |
|
73 |
+ return default_value
|
|
45 | 74 |
|
46 | 75 |
def resolve(self):
|
47 | 76 |
|
... | ... | @@ -22,6 +22,7 @@ |
22 | 22 |
import os
|
23 | 23 |
import itertools
|
24 | 24 |
from operator import itemgetter
|
25 |
+from collections import OrderedDict
|
|
25 | 26 |
|
26 | 27 |
from ._exceptions import PipelineError
|
27 | 28 |
from ._message import Message, MessageType
|
... | ... | @@ -479,7 +480,7 @@ class Pipeline(): |
479 | 480 |
#
|
480 | 481 |
class _Planner():
|
481 | 482 |
def __init__(self):
|
482 |
- self.depth_map = {}
|
|
483 |
+ self.depth_map = OrderedDict()
|
|
483 | 484 |
self.visiting_elements = set()
|
484 | 485 |
|
485 | 486 |
# Here we want to traverse the same element more than once when
|
... | ... | @@ -77,20 +77,17 @@ class Platform(): |
77 | 77 |
def get_host_os():
|
78 | 78 |
return os.uname()[0]
|
79 | 79 |
|
80 |
- # get_host_arch():
|
|
80 |
+ # canonicalize_arch():
|
|
81 | 81 |
#
|
82 |
- # This returns the architecture of the host machine. The possible values
|
|
83 |
- # map from uname -m in order to be a OS independent list.
|
|
82 |
+ # This returns the canonical, OS-independent architecture name
|
|
83 |
+ # or raises a PlatformError if the architecture is unknown.
|
|
84 | 84 |
#
|
85 |
- # Returns:
|
|
86 |
- # (string): String representing the architecture
|
|
87 | 85 |
@staticmethod
|
88 |
- def get_host_arch():
|
|
89 |
- # get the hardware identifier from uname
|
|
90 |
- uname_machine = os.uname()[4]
|
|
91 |
- uname_to_arch = {
|
|
86 |
+ def canonicalize_arch(arch):
|
|
87 |
+ aliases = {
|
|
88 |
+ "aarch32": "aarch32",
|
|
92 | 89 |
"aarch64": "aarch64",
|
93 |
- "aarch64_be": "aarch64-be",
|
|
90 |
+ "aarch64-be": "aarch64-be",
|
|
94 | 91 |
"amd64": "x86-64",
|
95 | 92 |
"arm": "aarch32",
|
96 | 93 |
"armv8l": "aarch64",
|
... | ... | @@ -99,17 +96,34 @@ class Platform(): |
99 | 96 |
"i486": "x86-32",
|
100 | 97 |
"i586": "x86-32",
|
101 | 98 |
"i686": "x86-32",
|
99 |
+ "power-isa-be": "power-isa-be",
|
|
100 |
+ "power-isa-le": "power-isa-le",
|
|
102 | 101 |
"ppc64": "power-isa-be",
|
103 | 102 |
"ppc64le": "power-isa-le",
|
104 | 103 |
"sparc": "sparc-v9",
|
105 | 104 |
"sparc64": "sparc-v9",
|
106 |
- "x86_64": "x86-64"
|
|
105 |
+ "sparc-v9": "sparc-v9",
|
|
106 |
+ "x86-32": "x86-32",
|
|
107 |
+ "x86-64": "x86-64"
|
|
107 | 108 |
}
|
109 |
+ |
|
108 | 110 |
try:
|
109 |
- return uname_to_arch[uname_machine]
|
|
111 |
+ return aliases[arch.replace('_', '-')]
|
|
110 | 112 |
except KeyError:
|
111 |
- raise PlatformError("uname gave unsupported machine architecture: {}"
|
|
112 |
- .format(uname_machine))
|
|
113 |
+ raise PlatformError("Unknown architecture: {}".format(arch))
|
|
114 |
+ |
|
115 |
+ # get_host_arch():
|
|
116 |
+ #
|
|
117 |
+ # This returns the architecture of the host machine. The possible values
|
|
118 |
+ # map from uname -m in order to be a OS independent list.
|
|
119 |
+ #
|
|
120 |
+ # Returns:
|
|
121 |
+ # (string): String representing the architecture
|
|
122 |
+ @staticmethod
|
|
123 |
+ def get_host_arch():
|
|
124 |
+ # get the hardware identifier from uname
|
|
125 |
+ uname_machine = os.uname()[4]
|
|
126 |
+ return Platform.canonicalize_arch(uname_machine)
|
|
113 | 127 |
|
114 | 128 |
##################################################################
|
115 | 129 |
# Sandbox functions #
|
... | ... | @@ -2441,11 +2441,17 @@ class Element(Plugin): |
2441 | 2441 |
# Sandbox config, unlike others, has fixed members so we should validate them
|
2442 | 2442 |
_yaml.node_validate(sandbox_config, ['build-uid', 'build-gid', 'build-os', 'build-arch'])
|
2443 | 2443 |
|
2444 |
+ build_arch = self.node_get_member(sandbox_config, str, 'build-arch', default=None)
|
|
2445 |
+ if build_arch:
|
|
2446 |
+ build_arch = Platform.canonicalize_arch(build_arch)
|
|
2447 |
+ else:
|
|
2448 |
+ build_arch = host_arch
|
|
2449 |
+ |
|
2444 | 2450 |
return SandboxConfig(
|
2445 | 2451 |
self.node_get_member(sandbox_config, int, 'build-uid'),
|
2446 | 2452 |
self.node_get_member(sandbox_config, int, 'build-gid'),
|
2447 | 2453 |
self.node_get_member(sandbox_config, str, 'build-os', default=host_os),
|
2448 |
- self.node_get_member(sandbox_config, str, 'build-arch', default=host_arch))
|
|
2454 |
+ build_arch)
|
|
2449 | 2455 |
|
2450 | 2456 |
# This makes a special exception for the split rules, which
|
2451 | 2457 |
# elements may extend but whos defaults are defined in the project.
|
... | ... | @@ -2,7 +2,7 @@ coverage==4.4 |
2 | 2 |
pylint==2.2.2
|
3 | 3 |
pycodestyle==2.4.0
|
4 | 4 |
pytest==4.0.2
|
5 |
-pytest-cov==2.6.0
|
|
5 |
+pytest-cov==2.6.1
|
|
6 | 6 |
pytest-datafiles==2.0
|
7 | 7 |
pytest-env==0.6.2
|
8 | 8 |
pytest-xdist==1.25.0
|
1 |
+kind: autotools
|
|
2 |
+variables:
|
|
3 |
+ result: "Nothing"
|
|
4 |
+ (?):
|
|
5 |
+ - machine_arch == "arm":
|
|
6 |
+ result: "Army"
|
|
7 |
+ - machine_arch == "x86_64":
|
|
8 |
+ result: "X86-64y"
|
1 |
+name: test
|
|
2 |
+ |
|
3 |
+options:
|
|
4 |
+ machine_arch:
|
|
5 |
+ type: arch
|
|
6 |
+ description: The machine architecture
|
|
7 |
+ values:
|
|
8 |
+ - arm
|
|
9 |
+ - x86_64
|
1 |
+kind: autotools
|
|
2 |
+variables:
|
|
3 |
+ result: "Nothing"
|
|
4 |
+ (?):
|
|
5 |
+ - machine_arch == "aarch32":
|
|
6 |
+ result: "Army"
|
|
7 |
+ - machine_arch == "aarch64":
|
|
8 |
+ result: "Aarchy"
|
|
9 |
+ - machine_arch == "x86-128":
|
|
10 |
+ result: "X86-128y"
|
1 |
+name: test
|
|
2 |
+ |
|
3 |
+options:
|
|
4 |
+ machine_arch:
|
|
5 |
+ type: arch
|
|
6 |
+ description: The machine architecture
|
|
7 |
+ values:
|
|
8 |
+ - aarch32
|
|
9 |
+ - aarch64
|
|
10 |
+ - x86-128
|
... | ... | @@ -75,3 +75,47 @@ def test_unsupported_arch(cli, datafiles): |
75 | 75 |
])
|
76 | 76 |
|
77 | 77 |
result.assert_main_error(ErrorDomain.LOAD, LoadErrorReason.INVALID_DATA)
|
78 |
+ |
|
79 |
+ |
|
80 |
+@pytest.mark.datafiles(DATA_DIR)
|
|
81 |
+def test_alias(cli, datafiles):
|
|
82 |
+ |
|
83 |
+ with override_uname_arch("arm"):
|
|
84 |
+ project = os.path.join(datafiles.dirname, datafiles.basename, 'option-arch-alias')
|
|
85 |
+ result = cli.run(project=project, silent=True, args=[
|
|
86 |
+ 'show',
|
|
87 |
+ '--deps', 'none',
|
|
88 |
+ '--format', '%{vars}',
|
|
89 |
+ 'element.bst'
|
|
90 |
+ ])
|
|
91 |
+ |
|
92 |
+ result.assert_success()
|
|
93 |
+ |
|
94 |
+ |
|
95 |
+@pytest.mark.datafiles(DATA_DIR)
|
|
96 |
+def test_unknown_host_arch(cli, datafiles):
|
|
97 |
+ |
|
98 |
+ with override_uname_arch("x86_128"):
|
|
99 |
+ project = os.path.join(datafiles.dirname, datafiles.basename, 'option-arch')
|
|
100 |
+ result = cli.run(project=project, silent=True, args=[
|
|
101 |
+ 'show',
|
|
102 |
+ '--deps', 'none',
|
|
103 |
+ '--format', '%{vars}',
|
|
104 |
+ 'element.bst'
|
|
105 |
+ ])
|
|
106 |
+ |
|
107 |
+ result.assert_main_error(ErrorDomain.PLATFORM, None)
|
|
108 |
+ |
|
109 |
+ |
|
110 |
+@pytest.mark.datafiles(DATA_DIR)
|
|
111 |
+def test_unknown_project_arch(cli, datafiles):
|
|
112 |
+ |
|
113 |
+ project = os.path.join(datafiles.dirname, datafiles.basename, 'option-arch-unknown')
|
|
114 |
+ result = cli.run(project=project, silent=True, args=[
|
|
115 |
+ 'show',
|
|
116 |
+ '--deps', 'none',
|
|
117 |
+ '--format', '%{vars}',
|
|
118 |
+ 'element.bst'
|
|
119 |
+ ])
|
|
120 |
+ |
|
121 |
+ result.assert_main_error(ErrorDomain.LOAD, LoadErrorReason.INVALID_DATA)
|
1 |
+import os
|
|
2 |
+ |
|
3 |
+import pytest
|
|
4 |
+from tests.testutils import cli, create_repo
|
|
5 |
+ |
|
6 |
+from buildstream import _yaml
|
|
7 |
+ |
|
8 |
+# Project directory
|
|
9 |
+DATA_DIR = os.path.join(
|
|
10 |
+ os.path.dirname(os.path.realpath(__file__)),
|
|
11 |
+ "project",
|
|
12 |
+)
|
|
13 |
+ |
|
14 |
+ |
|
15 |
+def create_element(repo, name, path, dependencies, ref=None):
|
|
16 |
+ element = {
|
|
17 |
+ 'kind': 'import',
|
|
18 |
+ 'sources': [
|
|
19 |
+ repo.source_config(ref=ref)
|
|
20 |
+ ],
|
|
21 |
+ 'depends': dependencies
|
|
22 |
+ }
|
|
23 |
+ _yaml.dump(element, os.path.join(path, name))
|
|
24 |
+ |
|
25 |
+ |
|
26 |
+# This tests a variety of scenarios and checks that the order in
|
|
27 |
+# which things are processed remains stable.
|
|
28 |
+#
|
|
29 |
+# This is especially important in order to ensure that our
|
|
30 |
+# depth sorting and optimization of which elements should be
|
|
31 |
+# processed first is doing it's job right, and that we are
|
|
32 |
+# promoting elements to the build queue as soon as possible
|
|
33 |
+#
|
|
34 |
+# Parameters:
|
|
35 |
+# targets (target elements): The targets to invoke bst with
|
|
36 |
+# template (dict): The project template dictionary, for create_element()
|
|
37 |
+# expected (list): A list of element names in the expected order
|
|
38 |
+#
|
|
39 |
+@pytest.mark.datafiles(os.path.join(DATA_DIR))
|
|
40 |
+@pytest.mark.parametrize("target,template,expected", [
|
|
41 |
+ # First simple test
|
|
42 |
+ ('3.bst', {
|
|
43 |
+ '0.bst': ['1.bst'],
|
|
44 |
+ '1.bst': [],
|
|
45 |
+ '2.bst': ['0.bst'],
|
|
46 |
+ '3.bst': ['0.bst', '1.bst', '2.bst']
|
|
47 |
+ }, ['1.bst', '0.bst', '2.bst', '3.bst']),
|
|
48 |
+ |
|
49 |
+ # A more complicated test with build of build dependencies
|
|
50 |
+ ('target.bst', {
|
|
51 |
+ 'a.bst': [],
|
|
52 |
+ 'base.bst': [],
|
|
53 |
+ 'timezones.bst': [],
|
|
54 |
+ 'middleware.bst': [{'filename': 'base.bst', 'type': 'build'}],
|
|
55 |
+ 'app.bst': [{'filename': 'middleware.bst', 'type': 'build'}],
|
|
56 |
+ 'target.bst': ['a.bst', 'base.bst', 'middleware.bst', 'app.bst', 'timezones.bst']
|
|
57 |
+ }, ['base.bst', 'middleware.bst', 'a.bst', 'app.bst', 'timezones.bst', 'target.bst']),
|
|
58 |
+])
|
|
59 |
+@pytest.mark.parametrize("operation", [('show'), ('fetch'), ('build')])
|
|
60 |
+def test_order(cli, datafiles, tmpdir, operation, target, template, expected):
|
|
61 |
+ project = os.path.join(datafiles.dirname, datafiles.basename)
|
|
62 |
+ dev_files_path = os.path.join(project, 'files', 'dev-files')
|
|
63 |
+ element_path = os.path.join(project, 'elements')
|
|
64 |
+ |
|
65 |
+ # FIXME: Remove this when the test passes reliably.
|
|
66 |
+ #
|
|
67 |
+ # There is no reason why the order should not
|
|
68 |
+ # be preserved when the builders is set to 1,
|
|
69 |
+ # the scheduler queue processing still seems to
|
|
70 |
+ # be losing the order.
|
|
71 |
+ #
|
|
72 |
+ if operation == 'build':
|
|
73 |
+ pytest.skip("FIXME: This still only sometimes passes")
|
|
74 |
+ |
|
75 |
+ # Configure to only allow one fetcher at a time, make it easy to
|
|
76 |
+ # determine what is being planned in what order.
|
|
77 |
+ cli.configure({
|
|
78 |
+ 'scheduler': {
|
|
79 |
+ 'fetchers': 1,
|
|
80 |
+ 'builders': 1
|
|
81 |
+ }
|
|
82 |
+ })
|
|
83 |
+ |
|
84 |
+ # Build the project from the template, make import elements
|
|
85 |
+ # all with the same repo
|
|
86 |
+ #
|
|
87 |
+ repo = create_repo('git', str(tmpdir))
|
|
88 |
+ ref = repo.create(dev_files_path)
|
|
89 |
+ for element, dependencies in template.items():
|
|
90 |
+ create_element(repo, element, element_path, dependencies, ref=ref)
|
|
91 |
+ repo.add_commit()
|
|
92 |
+ |
|
93 |
+ # Run test and collect results
|
|
94 |
+ if operation == 'show':
|
|
95 |
+ result = cli.run(args=['show', '--deps', 'plan', '--format', '%{name}', target], project=project, silent=True)
|
|
96 |
+ result.assert_success()
|
|
97 |
+ results = result.output.splitlines()
|
|
98 |
+ else:
|
|
99 |
+ if operation == 'fetch':
|
|
100 |
+ result = cli.run(args=['source', 'fetch', target], project=project, silent=True)
|
|
101 |
+ else:
|
|
102 |
+ result = cli.run(args=[operation, target], project=project, silent=True)
|
|
103 |
+ result.assert_success()
|
|
104 |
+ results = result.get_start_order(operation)
|
|
105 |
+ |
|
106 |
+ # Assert the order
|
|
107 |
+ print("Expected order: {}".format(expected))
|
|
108 |
+ print("Observed result order: {}".format(results))
|
|
109 |
+ assert results == expected
|
... | ... | @@ -167,6 +167,23 @@ class Result(): |
167 | 167 |
def assert_shell_error(self, fail_message=''):
|
168 | 168 |
assert self.exit_code == 1, fail_message
|
169 | 169 |
|
170 |
+ # get_start_order()
|
|
171 |
+ #
|
|
172 |
+ # Gets the list of elements processed in a given queue, in the
|
|
173 |
+ # order of their first appearances in the session.
|
|
174 |
+ #
|
|
175 |
+ # Args:
|
|
176 |
+ # activity (str): The queue activity name (like 'fetch')
|
|
177 |
+ #
|
|
178 |
+ # Returns:
|
|
179 |
+ # (list): A list of element names in the order which they first appeared in the result
|
|
180 |
+ #
|
|
181 |
+ def get_start_order(self, activity):
|
|
182 |
+ results = re.findall(r'\[\s*{}:(\S+)\s*\]\s*START\s*.*\.log'.format(activity), self.stderr)
|
|
183 |
+ if results is None:
|
|
184 |
+ return []
|
|
185 |
+ return list(results)
|
|
186 |
+ |
|
170 | 187 |
# get_tracked_elements()
|
171 | 188 |
#
|
172 | 189 |
# Produces a list of element names on which tracking occurred
|