Source code for celestia.types.das

from dataclasses import dataclass




@dataclass
class Worker:
    job_type: str
    current: int
    from_: int
    to: int





@dataclass
class SamplingStats:
    head_of_sampled_chain: int
    head_of_catchup: int
    network_head_height: int
    concurrency: int
    catch_up_done: bool
    is_running: bool
    workers: tuple[Worker, ...] = None

    def __init__(self, head_of_sampled_chain, head_of_catchup, network_head_height, concurrency, catch_up_done,
                 is_running, workers=None):
        self.head_of_sampled_chain = head_of_sampled_chain
        self.head_of_catchup = head_of_catchup
        self.network_head_height = network_head_height
        self.concurrency = concurrency
        self.catch_up_done = catch_up_done
        self.is_running = is_running
        self.workers = tuple(Worker(**worker) for worker in workers) if workers is not None else None

    @staticmethod
    def deserializer(result):
        if result is not None:
            return SamplingStats(**result)