6477087494

Committed 06 Oct 2023 05:49AM UTC coverage: 94.685% (+0.2%) from 94.473%

Build # 6477087494

Build Type

push

github

Committed by

charettes

Commit Message

Fix #35 - Propagate migration crashes to quorum parties.

This ensures remote parties terminate immediately when the party that
attained pre-migration quorum crashes when applying migrations.

This is achieved by introducing a concept of quorum severance and implemented
in the cache backend by assigning a negative quorum value to the namespace
which can be detected by other parties.

Run Details

182 of 204 branches covered (0.0%)

Branch coverage included in aggregate %.

31 of 31 new or added lines in 5 files covered. (100.0%)

1 existing line in 1 file now uncovered.

584 of 605 relevant lines covered (96.53%)

4.82 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

80.0

/syzygy/quorum/backends/base.py

from abc import ABC, abstractmethod


class QuorumBase(ABC):
    """
    An abstraction to allow multiple parties to obtain quorum before
    proceeding with a coordinated action.

    For a particular `namespace` the `join` method must be called
    `quorum` times and `poll` must be called ``quorum - 1`` times or
    for each party that got returned `False` when calling `join`.

    The `sever` method must be called instead of `join` by parties
    that do not intend to participate in attaining `namespace`'s quorum.
    It must result in other parties raising `QuorumDisolved` on their next
    `poll` for that `namespace`.
    """

    @abstractmethod
    def join(self, namespace: str, quorum: int) -> bool:
        """Join the `namespace` and return whether or not `quorum` was attained."""
        ...

    @abstractmethod
    def sever(self, namespace: str, quorum: int):
        """Sever the `namespace`'s quorum attainment process."""

    @abstractmethod
    def poll(self, namespace: str, quorum: int) -> bool:
        """
        Return whether or not `namespace`'s `quorum` was reached.

        Raise `QuorumDisolved` if the quorom attainment process was
        severed.
        """
        ...

1	from abc import ABC, abstractmethod	5✔
2
3
4	class QuorumBase(ABC):	5✔
5	"""
6	An abstraction to allow multiple parties to obtain quorum before
7	proceeding with a coordinated action.
8
9	For a particular `namespace` the `join` method must be called
10	`quorum` times and `poll` must be called ``quorum - 1`` times or
11	for each party that got returned `False` when calling `join`.
12
13	The `sever` method must be called instead of `join` by parties
14	that do not intend to participate in attaining `namespace`'s quorum.
15	It must result in other parties raising `QuorumDisolved` on their next
16	`poll` for that `namespace`.
17	"""
18
19	@abstractmethod	5✔
20	def join(self, namespace: str, quorum: int) -> bool:	5✔
21	"""Join the `namespace` and return whether or not `quorum` was attained."""
22	...	×
23
24	@abstractmethod	5✔
25	def sever(self, namespace: str, quorum: int):	5✔
26	"""Sever the `namespace`'s quorum attainment process."""
27
28	@abstractmethod	5✔
29	def poll(self, namespace: str, quorum: int) -> bool:	5✔
30	"""
31	Return whether or not `namespace`'s `quorum` was reached.
32
33	Raise `QuorumDisolved` if the quorom attainment process was
34	severed.
35	"""
UNCOV 36	...	×

charettes / django-syzygy / 6477087494

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous